[ https://issues.apache.org/jira/browse/FLINK-15111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Konstantin Knauf reopened FLINK-15111: -------------------------------------- Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > java.lang.RuntimeException for > KafkaPartitionDiscoverer.getAllPartitionsForTopics(KafkaPartitionDiscoverer.java:80) > when using SASL_SSL > ---------------------------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-15111 > URL: https://issues.apache.org/jira/browse/FLINK-15111 > Project: Flink > Issue Type: Bug > Components: Connectors / Kafka > Affects Versions: 1.9.0 > Environment: Flink Version 1.9.0 > Scala Version 2.11.12 > Kafka Cluster Version 2.3.0 > Reporter: Hunter Kempf > Priority: Minor > Labels: auto-closed > > > Problem: When I attempt to connect to a kafka topic that doesn't exist on I > get the following error: > > ``` > > {{java.lang.RuntimeException: topicName > at > org.apache.flink.streaming.connectors.kafka.internal.KafkaPartitionDiscoverer.getAllPartitionsForTopics(KafkaPartitionDiscoverer.java:80) > at > org.apache.flink.streaming.connectors.kafka.internals.AbstractPartitionDiscoverer.discoverPartitions(AbstractPartitionDiscoverer.java:131) > at > org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.open(FlinkKafkaConsumerBase.java:508) > at > org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36) > at > org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:529) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:393) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:530) > at java.lang.Thread.run(Thread.java:748)}} > ``` > Based on the KafkaPartitionDiscoverer.Java code this runtime exception > should return ("Could not fetch partitions for %s. Make sure that the topic > exists.") > > [https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaPartitionDiscoverer.java] > > -- This message was sent by Atlassian Jira (v8.3.4#803005)