From 2b6d063085dc6bab9e84cc5c714be5cf2716fe38 Mon Sep 17 00:00:00 2001
From: Zack Dever <zdever@pandora.com>
Date: Wed, 16 Mar 2016 16:21:37 -0700
Subject: KAFKA-2698: add paused API

---
 kafka/consumer/group.py | 8 ++++++++
 1 file changed, 8 insertions(+)

(limited to 'kafka/consumer/group.py')

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.
 
-- 
cgit v1.2.1