Flink实战系列Flink 1.14.0 消费 kafka 数据自定义反序列化器
Posted JasonLee-后厂村程序员
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink实战系列Flink 1.14.0 消费 kafka 数据自定义反序列化器相关的知识，希望对你有一定的参考价值。
Flink 1.14.0 消费 kafka 数据自定义反序列类
在最近刚发布的 Flink 1.14.0 版本中 Source 接口进行了重构,API 的变化还是非常大的,那在新的接口下消费 kafka 的时候如何自定义反序列类呢?
Kafka Source
使用
Kafka source 提供了一个构建类来构造 KafkaSource 的实例。下面的代码片段展示了如何构建一个 KafkaSource 来消费 topic input-topic 的最早偏移量的消息，使用消费组 my-group，并且只将 message 的值反序列化为字符串。
KafkaSource<String> source = KafkaSource.<String>bu以上是关于Flink实战系列Flink 1.14.0 消费 kafka 数据自定义反序列化器的主要内容，如果未能解决你的问题，请参考以下文章
Flink 实战系列Flink 消费多个 Topic 数据利用侧流输出完成分流功能
Flink实战系列Flink 消费多个 topic 的数据根据不同 topic 数据做不同的处理逻辑