问题1
图一就只能看出消息推送失败…
图二是 网络连接超时了，这个要检查下 问题发生的时刻，网络是否存在问题，或者kafka 的服务是否正常
问题2
kafka 推送的规则，是按照配置过程来处理的
https://docs.pingcap.com/zh/tidb/stable/manage-ticdc#自定义-kafka-sink-的-topic-和-partition-的分发规则
建议检查分发规则，是否按照文档上的描述来配置的，另外是否符合场景的需求
https://docs.pingcap.com/zh/tidb/stable/manage-ticdc#自定义-kafka-sink-的-topic-和-partition-的分发规则
1 个赞