[ 
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)

Reply via email to