开发者社区> 问答> 正文

请叫一个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 6822 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
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载