tiflow icon indicating copy to clipboard operation
tiflow copied to clipboard

ticdc: detection Kafka version is not the expected version

Open wk989898 opened this issue 9 months ago • 1 comments

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

wk989898 avatar May 08 '24 02:05 wk989898

/severity moderate

fubinzh avatar May 09 '24 03:05 fubinzh