Skip to content
This repository was archived by the owner on Jan 26, 2022. It is now read-only.

Commit 5e77407

Browse files
committed
ZK Brokers wasn't actually creating the tuples as specified.
Correct that, so 'id' is the broker ID in the Kafka properties file.
1 parent dbd44c8 commit 5e77407

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

zkclient.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ def brokers(self, broker_root='/brokers'):
3737
try:
3838
for c in self.client.get_children(id_root):
3939
n = self.client.get(self._zjoin([id_root, c]))[0]
40-
b.append(ZkKafkaBroker._make(n.split(':')))
40+
b.append(ZkKafkaBroker(c, n.split(':')[1], n.split(':')[2]))
4141
except NoNodeError:
4242
raise ZkError('Broker nodes do not exist in Zookeeper')
4343
self.client.stop()

0 commit comments

Comments
 (0)