[FLINK-13506] flink1.6.1 can't consume the specified topic list，only a few topic was consumed

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Connectors / Kafka
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: jiangxiaozhi
• Created: 31/Jul/19 07:54
• Updated: 23/Nov/21 22:38

Description

i  specified topic list in my config file, and the flink program read message from this.

here is my config file:

 

kafka.consumer.topic = user，order，sales

 

and flink program :

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(5000);
FlinkKafkaConsumer010 kafkaConsumer = new FlinkKafkaConsumer010<>(Arrays.asList(kafka_consumer_topic.split(",")), new SimpleStringSchema(), getKafkaProperties());
DataStream<String> dataStream = env.addSource(kafkaConsumer);

when i run the flink program，it is only can consume a few topics，the others can't consume，can anyone help me？flink version is 1.6.1。