Github user alexpf commented on a diff in the pull request:
https://github.com/apache/flink/pull/5929#discussion_r186110995
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09PartitionDiscoverer.java
Github user alexpf commented on a diff in the pull request:
https://github.com/apache/flink/pull/5929#discussion_r185745293
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09PartitionDiscoverer.java
GitHub user alexpf opened a pull request:
https://github.com/apache/flink/pull/5929
[FLINK-8497] [connectors] KafkaConsumer throws NPE if topic doesn't exist
## What is the purpose of the change
To make the Kafka connector behavior clearer for the API user, by throwi
