This repository was archived by the owner on Jul 15, 2023. It is now read-only.
This repository was archived by the owner on Jul 15, 2023. It is now read-only.
In BrokerPartitionInfo.cs list of brokers is never refreshed from Zookeeper #32
Open
Description
BrokerPartitionInfo UpdateInfo() is used by KafkaSimpleManager.RefreshMetadataInternal() to find new leader of partitions.
The problem is that even if ZkUtils.GetTopicMetadataInzookeeper() is called, the list of broker used for metadata call is from syncProducerPool and is never refreshed from Zookeeper because ZkUtils.GetAllBrokersInCluster() is only called once.
Metadata
Metadata
Assignees
Labels
No labels