Dong Lin created KAFKA-5086:
-------------------------------

             Summary: Topic expiry time in Metadata should be updated 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


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)

Reply via email to