请叫一个flink和kafka集成问题，如果用这个API（FlinkKafkaConsumer010(List<String> topics, DeserializationSchema<T> deserializer, Properties props)）同时读多个topic，用什么Schema，能在收到的消息中得到这个消息时来自哪个topic？
转自钉钉群21789141：请叫一个flink和kafka集成问题，如果用这个API（FlinkKafkaConsumer010(List topics, DeserializationSchema deserializer, Properties props)）同时读多个topic，用什么Schema，能在收到的消息中得到这个消息时来自哪个topic？
我知道可以用多个stream，map一下加上topicname，再union在一起。但是这样稍麻烦，如果能直接从多topic API中收到的消息里得到来自哪个topic，程序写的简单些。
展开
收起
3
条回答
写回答
写回答
-
-
同问，为什么FlinkKafkaConsumer010 不能使用SimpleStringSchema
楼主有新的 DeserializationSchema 实现方式么？2019-07-17 23:11:17赞同 展开评论 打赏 -
石权：KeyedDeserializationSchema 接口中有返回topic、partition、offset。topicList这种应该是表示的是来自多个topic的同一种数据，schema共用。
2019-07-17 23:11:17赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
