flink1.9.1 支持一个 source 指定消费多个 topics么？
最近通过flink_taskmanager_job_task_operator_KafkaConsumer_records_consumed_rate指标发现， flink某个任务消费一个topic A 竟然比消费topic A,B,C,D一起的指标要高， 也就是我四个topic每秒消费的数据竟然还没其中一个topic每秒消费的数据高， 所以想请问：flink1.9.1 支持一个 source 指定消费多个 topics么？ 我的代码如下： val A= params.getProperty("kafka.scene.data.topic") val B= params.getProperty("kafka.scene.log.topic") val C= params.getProperty("kafka.event.topic") val D= params.getProperty("kafka.log.topic") import scala.collection.JavaConverters._ val topics = List[String](sceneDataTopic, sceneLogTopic, eventTopic, sdkLog).asJava env .addSource(new FlinkKafkaConsumer011(topics, new JSONKeyValueDeserializationSchema(false), kafkaPro))*来自志愿者整理的flink邮件归档
写回答
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
