[GitHub] flink issue #5929: [FLINK-8497] [connectors] KafkaConsumer throws NPE if top...

2018-05-11 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5929 @alexpf thanks for the updates. Please bear with me just a little, I'll try to get back to reviewing this PR ASAP after I finish with some ongoing tasks. ---

[GitHub] flink issue #5929: [FLINK-8497] [connectors] KafkaConsumer throws NPE if top...

2018-05-03 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5929 I am not sure if failing is the right behavior here. What is someone has a Flink job running and one of the topics for which partitions are discovered gets deleted? That would fail the