ticdc到kafka那边经常丢消息，有没有什么办法，从ticdc源头侧做一个数据记录，判断增量数据的传输过程中是否出现问题。