diff options
| author | Zack Dever <zdever@pandora.com> | 2016-03-16 16:21:37 -0700 |
|---|---|---|
| committer | Zack Dever <zdever@pandora.com> | 2016-03-16 18:01:17 -0700 |
| commit | 2b6d063085dc6bab9e84cc5c714be5cf2716fe38 (patch) | |
| tree | 492047c98a8d4e33d9f824ab30554ab698ba0404 /kafka/consumer/group.py | |
| parent | ab7c80db8fb662d8204bd20754dfa66a341276c6 (diff) | |
| download | kafka-python-2b6d063085dc6bab9e84cc5c714be5cf2716fe38.tar.gz | |
KAFKA-2698: add paused API
Diffstat (limited to 'kafka/consumer/group.py')
| -rw-r--r-- | kafka/consumer/group.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 32a4a49..415704e 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -527,6 +527,14 @@ class KafkaConsumer(six.Iterator): log.debug("Pausing partition %s", partition) self._subscription.pause(partition) + def paused(self): + """Get the partitions that were previously paused by a call to pause(). + + Returns: + set: {partition (TopicPartition), ...} + """ + return self._subscription.paused_partitions() + def resume(self, *partitions): """Resume fetching from the specified (paused) partitions. |