diff options
Diffstat (limited to 'kafka/cluster.py')
| -rw-r--r-- | kafka/cluster.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/cluster.py b/kafka/cluster.py index 5be3c2f..45f25ad 100644 --- a/kafka/cluster.py +++ b/kafka/cluster.py @@ -96,6 +96,7 @@ class ClusterMetadata(object): Returns: set: {partition (int), ...} + None if topic not found. """ if topic not in self._partitions: return None @@ -119,6 +120,7 @@ class ClusterMetadata(object): Returns: set: {TopicPartition, ...} + None if the broker either has no partitions or does not exist. """ return self._broker_partitions.get(broker_id) @@ -130,6 +132,7 @@ class ClusterMetadata(object): Returns: int: node_id for group coordinator + None if the group does not exist. """ return self._groups.get(group) |