Skip to content

ticdc: detection Kafka version is not the expected version #11047

@wk989898

Description

@wk989898

What did you do?

create a changefeed with kafka protocol
bin/cdc cli changefeed create -c test --sink-uri "kafka://127.0.0.1:9092/test?topic=test&protocol=open-protocol&max-message-bytes=41943040&compressionType=ZLIB&kafka-version=0.11.0.0"

What did you expect to see?

[WARN] [sarama.go:139] ["The Kafka version you assigned may not be correct. Please assign a version equal to or less than the specified version"] [assignedVersion=0.11.0.0] [desiredVersion=2.8.0]

What did you see instead?

[WARN] [sarama.go:226] ["Kafka fail to get ApiVersions"] [addr=127.0.0.1:9092]

Versions of the cluster

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

v8.0.0

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

v8.0.0

TiCDC version (execute cdc version):

v8.2.0-master-dirty

Kafka version

kafka_2.13-3.7.0

Metadata

Metadata

Assignees

Labels

affects-7.5This bug affects the 7.5.x(LTS) versions.affects-8.1This bug affects the 8.1.x(LTS) versions.area/ticdcIssues or PRs related to TiCDC.severity/moderatetype/bugThe issue is confirmed as a bug.

Type

No type

Projects

Status

Done

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions