Skip to content
This repository has been 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
maximecaron opened this issue Mar 17, 2016 · 1 comment
Open

In BrokerPartitionInfo.cs list of brokers is never refreshed from Zookeeper #32

maximecaron opened this issue Mar 17, 2016 · 1 comment

Comments

@maximecaron
Copy link

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.
@maximecaron
Copy link
Author

fixed in pull request #34

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@maximecaron