File tree Expand file tree Collapse file tree 1 file changed +0
-2
lines changed Expand file tree Collapse file tree 1 file changed +0
-2
lines changed Original file line number Diff line number Diff line change @@ -339,7 +339,6 @@ def _find_coordinator_id(self, group_id):
339
339
name as a string.
340
340
:return: The node_id of the broker that is the coordinator.
341
341
"""
342
- # Note: Java may change how this is implemented in KAFKA-6791.
343
342
future = self ._find_coordinator_id_send_request (group_id )
344
343
self ._wait_for_futures ([future ])
345
344
response = future .value
@@ -357,7 +356,6 @@ def _find_many_coordinator_ids(self, group_ids):
357
356
:return: A list of tuples (group_id, node_id) where node_id is the id
358
357
of the broker that is the coordinator for the corresponding group.
359
358
"""
360
- # Note: Java may change how this is implemented in KAFKA-6791.
361
359
futures = {
362
360
group_id : self ._find_coordinator_id_send_request (group_id )
363
361
for group_id in group_ids
You can’t perform that action at this time.
0 commit comments