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)
