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 的实际版本保持一致。