用flink-tidb-cdc SourceFunction方式获取tidb变更日志,解析出来是二进制,请问该如何转换为正常内容 【附件:截图/日志/监控】
好像不行,以前也找了很多办法,发现都搞不出来
为什么要取这个呢
flink sql方式試過嗎?可以做到不
解析成变更的日志数据啊,然后做业务操作啊
通过Ticdc同步到Kafka Flink再从Kafka中消费 与 Apache Kafka 和 Apache Flink 进行数据集成 | PingCAP 文档中心