Skip to content

Invalid group id error on Kafka #2639

@phuongvu

Description

@phuongvu

What did you do?

I'm running on the cdc-v9.0.0-beta.2.pre-nightly-linux-arm64.tar.gz bin and created two changefeeds. The changefeeds are running properly. However, I'm seeing a ton of logs on my Kafka cluster with invalid_group_id errors. Our team member did a TCP dump, and we can see that CDC is passing empty value for group.

Image

What did you expect to see?

No invalid_group_id since TiCDC should only be a producer.

What did you see instead?

invalid_group_id

Image

Versions of the cluster

Upstream TiDB cluster version (execute SELECT tidb_version(); in a MySQL client):

Release Version: v8.5.1
Edition: Community
Git Commit Hash: fea86c8e35ad4a86a5e1160701f99493c2ee547c
Git Branch: HEAD
UTC Build Time: 2025-01-16 07:38:34
GoVersion: go1.23.4
Race Enabled: false
Check Table Before Drop: false
Store: tikv

Upstream TiKV version (execute tikv-server --version):

TiKV
Release Version:   8.5.1
Edition:           Community
Git Commit Hash:   25897b73e1f0e93f616c764dbe65ed7db02edd07
Git Commit Branch: HEAD
UTC Build Time:    2025-01-14 05:01:11
Rust Version:      rustc 1.77.0-nightly (89e2160c4 2023-12-27)
Enable Features:   memory-engine pprof-fp jemalloc mem-profiling portable test-engine-kv-rocksdb test-engine-raft-raft-engine trace-async-tasks openssl-vendored
Profile:           dist_release

TiCDC version (execute cdc version):

Release Version: v9.0.0-beta.2.pre-68-g2489c4e
Git Commit Hash: 2489c4e7fbc2e426281b916bfbd9f6b3639ca4cf
Git Branch: HEAD
UTC Build Time: 2025-08-06 16:47:19
Go Version: go version go1.23.10 linux/arm64
Failpoint Build: false

Metadata

Metadata

Assignees

Labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions