ticdc 都支持哪些版本的 kafka?

TiCDC 支持 Kafka 的多个版本,包括最新的 3.6 版本。

具体来说,TiCDC 支持的 Kafka 版本如下:

  • 0.11.0.2
  • 0.11.1.0
  • 0.11.1.1
  • 0.11.2.0
  • 0.11.2.1
  • 0.11.2.2
  • 1.0.0
  • 1.0.1
  • 1.0.2
  • 1.1.0
  • 1.1.1
  • 2.0.0
  • 2.0.1
  • 2.1.0
  • 2.1.1
  • 2.2.0
  • 2.2.1
  • 2.3.0
  • 2.3.1
  • 2.4.0
  • 2.4.1
  • 3.x.x

您可以在创建 TiCDC 复制任务时,通过 sink URI 参数来指定 Kafka 的版本。例如:

–sink-uri= “kafka://127.0.0.1:9092/topic-name?protocol=canal-json&kafka-version=3.x.x&partition-num=6&max-message-bytes=67108864&replication-factor=1”

其中,kafka-version 参数就是用来设置 Kafka 的版本。这个值需要和下游 Kafka 的实际版本保持一致。