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

[Shang Yuanchun (Jira)]

jiangxiaozhi created FLINK-13506:
------------------------------------

             Summary: flink1.6.1 can't consume the specified topic list，only a few topic was consumed
                 Key: FLINK-13506
                 URL: https://issues.apache.org/jira/browse/FLINK-13506
             Project: Flink
          Issue Type: Bug
            Reporter: jiangxiaozhi


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

here is my config file:

 
{code:java}
kafka.consumer.topic = user，order，sales
{code}
 

and flink program :
{code:java}

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);
{code}
when i run the flink grogram，it is only can consume a few topics，the others can't consume，can anyone help me？flink version is 1.6.1。



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)