File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -93,7 +93,7 @@ def broker_metadata(self, broker_id):
93
93
"""Get BrokerMetadata
94
94
95
95
Arguments:
96
- broker_id (int): node_id for a broker to check
96
+ broker_id (int or str ): node_id for a broker to check
97
97
98
98
Returns:
99
99
BrokerMetadata or None if not found
@@ -148,7 +148,7 @@ def partitions_for_broker(self, broker_id):
148
148
"""Return TopicPartitions for which the broker is a leader.
149
149
150
150
Arguments:
151
- broker_id (int): node id for a broker
151
+ broker_id (int or str ): node id for a broker
152
152
153
153
Returns:
154
154
set: {TopicPartition, ...}
@@ -163,7 +163,7 @@ def coordinator_for_group(self, group):
163
163
group (str): name of consumer group
164
164
165
165
Returns:
166
- int: node_id for group coordinator
166
+ node_id ( int or str) for group coordinator, -1 if coordinator unknown
167
167
None if the group does not exist.
168
168
"""
169
169
return self ._groups .get (group )
You can’t perform that action at this time.
0 commit comments