开发者社区> 问答> 正文

请叫一个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,程序写的简单些。

展开
收起
赵慧@ApacheFlink中文社区 2018-10-30 17:28:57 6818 0
3 条回答
写回答
取消 提交回答
  • image.png

    2019-12-05 12:01:04
    赞同 展开评论 打赏
  • 同问,为什么FlinkKafkaConsumer010 不能使用SimpleStringSchema
    楼主有新的 DeserializationSchema 实现方式么?

    2019-07-17 23:11:17
    赞同 展开评论 打赏
  • 石权:KeyedDeserializationSchema 接口中有返回topic、partition、offset。topicList这种应该是表示的是来自多个topic的同一种数据,schema共用。

    2019-07-17 23:11:17
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
阿里邮箱—安全高效集成 立即下载
集成智能接入网关APP:优化企业级移动办公网络 立即下载
云效助力企业集成安全到DevOps中 立即下载