Tzu-Li (Gordon) Tai created FLINK-9303:
------------------------------------------
Summary: Unassign partitions from Kafka client if partitions
become unavailable
Key: FLINK-9303
URL: https://issues.apache.org/jira/browse/FLINK-9303
Project: Flink
Issue Type: Improvement
Components: Kafka Connector
Reporter: Tzu-Li (Gordon) Tai
Fix For: 1.6.0
Originally reported in ML:
[http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Dynamically-deleting-kafka-topics-does-not-remove-partitions-from-kafkaConsumer-td19946.html]
The problem is that the Kafka consumer has no notion of "closed" partitions at
the moment, so statically assigned partitions to the Kafka client is never
removed and is always continuously requested for records.
This causes LOG noises as reported in the reported mail thread.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
