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)
