CDC 同步数据至kafka数据解析

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

为提高效率，提问时请提供以下信息，问题描述清晰可优先响应。

  • 【TiDB 版本】：4.0.0 GA
  • 【问题描述】：请问CDC同步数据到kafka的，有java 解析kafka中的消息的demo？
2

您好，当前只有go 版本的解析 demo，请参考 https://github.com/pingcap/ticdc/tree/master/kafka_consumer 。

注意：只是 demo ，不要使用在生产环境，多谢。请看下私信，感谢

3

你好目前cdc任务暂停重启后 kafka接受不到消息
cdc.log (9.4 KB)

4

1.集群

image
image1455×268 41.3 KB

2.
cdc.log (1.3 MB)
cdc_stderr.log (590 字节)

5

这个问题您应该和其他同事在处理了，有结论了，请帮忙更新下，多谢。

6

请问这个问题后台有结果了吗？

7

如果你遇到新的问题，可以重新发帖咨询一下~

8

此话题已在最后回复的 1 分钟后被自动关闭。不再允许新回复。