flink-tidb-cdc获取日志,打印是乱码问题

用flink-tidb-cdc SourceFunction方式获取tidb变更日志,解析出来是二进制,请问该如何转换为正常内容
【附件:截图/日志/监控】

好像不行,以前也找了很多办法,发现都搞不出来

为什么要取这个呢

flink sql方式試過嗎?可以做到不

解析成变更的日志数据啊,然后做业务操作啊

通过Ticdc同步到Kafka Flink再从Kafka中消费 与 Apache Kafka 和 Apache Flink 进行数据集成 | PingCAP 文档中心