Raise AssertionError if consumer closed in poll()

1 files changed, 1 insertions, 0 deletions

diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py
index cde956c..bdf0894 100644
--- a/kafka/consumer/group.py
+++ b/kafka/consumer/group.py
@@ -638,6 +638,7 @@ class KafkaConsumer(six.Iterator):
             max_records = self.config['max_poll_records']
         assert isinstance(max_records, int), 'max_records must be an integer'
         assert max_records > 0, 'max_records must be positive'
+        assert not self._closed, 'KafkaConsumer is closed'
 
         # Poll for new data until the timeout expires
         start = time.time()