OSCHINA 社区最新专区文章 |
| Flink实时消费Kafka中的binlog日志乱码(反序列化失败) Posted: 22 Feb 2022 12:17 AM PST 业务场景： Canal将mysql的binlog日志上报到Kafka，通过Flink实时程序消费该binlog信息进行实时展示。 异常信息： 数据消费正常，但是显示乱码。 初步诊断： Canal上报binlog到Kafka时做了序列化，而代码中反序列化失败。 源码如下： import org.apache.flink.api.common.serialization.{DeserializationSchema, SimpleS... |
| You are subscribed to email updates from OSCHINA 社区最新专区文章. To stop receiving these emails, you may unsubscribe now. | Email delivery powered by Google |
| Google, 1600 Amphitheatre Parkway, Mountain View, CA 94043, United States | |
No comments:
Post a Comment