We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 11cf397 commit c9d783aCopy full SHA for c9d783a
kafka/cluster.py
@@ -96,6 +96,7 @@ def available_partitions_for_topic(self, topic):
96
97
Returns:
98
set: {partition (int), ...}
99
+ None if topic not found.
100
"""
101
if topic not in self._partitions:
102
return None
@@ -119,6 +120,7 @@ def partitions_for_broker(self, broker_id):
119
120
121
122
set: {TopicPartition, ...}
123
+ None if the broker either has no partitions or does not exist.
124
125
return self._broker_partitions.get(broker_id)
126
@@ -130,6 +132,7 @@ def coordinator_for_group(self, group):
130
132
131
133
134
int: node_id for group coordinator
135
+ None if the group does not exist.
136
137
return self._groups.get(group)
138
0 commit comments