link1.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.getProper
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.