tidb通过ticdc同步到kafka，kafka中没有数据

🪐 TiDB 技术问题 备份&数据迁移
10

您好，Flink 最佳实践之 通过 TiCDC 将 TiDB 数据流入 Flink 中有 ticdc 同步到 kafka 的 step by step 的配置方式。您可以看一下。

  1. 请先在 test database 下创建 t1(id int primary key, name varchar(20)) 进行测试，确保是有 pk 的
  2. 如果 cdc 同步正常，每隔一两秒中会会在 cdc 的 log 中打印出这期间一共同步了多少行数据。从您的日志中我没有看到相关的信息，这里我猜想数据还没有同步到 cdc 中，所以应该不是 kafka 的问题
  3. 此外，我看您说，kafka 的版本是 2.8.0（我装的kafka的版本号kafka_2.12-2.8.0），那么在您的 sink 中，请替换一下您的 kafka-version “kafka://192.168.104.113:9092/zlg_2?kafka-version=2.4.0&replication-factor=1”，这里的 2.4.0 换成 2.8.0。但这不是本次同步失败的原因，后面可能会引发异常。