flink1.9.1 支持一个 source 指定消费多个 topics么？

Thu, 17 Dec 2020 23:53:41 -0800 

Hi，想请教一下大家：

最近通过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))




-----
Best Wishes
--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复