tiflow
tiflow copied to clipboard
ticdc: detection Kafka version is not the expected version
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
/severity moderate