[ https://issues.apache.org/jira/browse/FLINK-13506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897003#comment-16897003 ]
Robert Metzger commented on FLINK-13506: ---------------------------------------- Hi, I would like to ask you to refer to the user@ mailing list for such support questions: https://flink.apache.org/community.html#mailing-lists But since you are already here: Are you sure that the splitting of the string by "," works with the spaces. Does it work when you set your config file to: {code:java} kafka.consumer.topic = user,order,sales {code} > 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 > Components: Connectors / Kafka > Reporter: jiangxiaozhi > Priority: Major > > 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 program,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)