[ https://issues.apache.org/jira/browse/KAFKA-5086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rajini Sivaram resolved KAFKA-5086. ----------------------------------- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2869 [https://github.com/apache/kafka/pull/2869] > Update topic expiry time in Metadata every time the topic metadata is > requested > ------------------------------------------------------------------------------- > > Key: KAFKA-5086 > URL: https://issues.apache.org/jira/browse/KAFKA-5086 > Project: Kafka > Issue Type: Bug > Reporter: Dong Lin > Assignee: Dong Lin > Fix For: 0.11.0.0 > > > As of current implementation, KafkaProducer.waitOnMetadata() will first reset > topic expiry time of the topic before repeatedly sending TopicMetadataRequest > and waiting for metadata response. However, if the metadata of the topic is > not available within Metadata.TOPIC_EXPIRY_MS, which is set to 5 minutes, > then the topic will be expired and removed from Metadata.topics. The > TopicMetadataRequest will no longer include the topic and the KafkaProducer > will never receive the metadata of this topic. It will enter an infinite loop > of sending TopicMetadataRequest and waiting for metadata response. > This problem can be fixed by updating topic expiry time every time the topic > metadata is requested. -- This message was sent by Atlassian JIRA (v6.3.15#6346)