[
https://issues.apache.org/jira/browse/KAFKA-5086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-5086:
----------------------------
Summary: Update topic expiry time in Metadata every time the topic metadata
is requested (was: Topic expiry time in Metadata should be updated every time
the topic metadata is requested)
> 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
>
> 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)
