You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Shengnan YU <ys...@hotmail.com> on 2019/04/15 13:21:05 UTC

[Jira][Created](KAFKA-8100)kafka consumer not refresh metadata for dynamic topic deletion

Hi everyone:
I found that KafkaConsumer will not refresh its topic metadata when some unused topics are deleted, which leads to continuous UNKNOWN_TOPIC_PARTITION warning. In source code KafkaProducer will remove unused topic after a expire time but KafkaConsumer not. I know it may be a design that because UNKNOWN_TOPIC_PARTITION may not assert the non-existence of topic but is it possible to make the topic expirable configurable for KafkaConsumer? I think even the topic info is removed by mistake, it can still be discovered soon. Thank you very much!

Yu Shengnan