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)