flink解析ticdc发送到kafka数据

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

【概述】 flink解析ticdc发送到kafka数据

【问题】 当前遇到的问题
kafka consumer属性的key和value的反序列化类怎么设置，才能对接ticdc的java demo里的KafkaMessage类
consumerProps.put(“key.deserializer”, “？？？”);
consumerProps.put(“value.deserializer”, “？？？”);

2

Hello ~ 可以参考一下这段代码，应该可以 match 到你现在的需求。

https://github.com/liuzix/TiBigData/blob/zixiong/flink/src/main/java/com/pingcap/flink/ticdc/TiCDCStreamProvider.java#L58-L60

可以尝试一下 TiBigdata