From 65b343de9b30d7c50060d8d3264b3e96bdc7fee0 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Sun, 29 Dec 2019 12:52:51 -0800
Subject: StopIteration when consumer closed

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

diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py
index bdf0894..bbdf206 100644
--- a/kafka/consumer/group.py
+++ b/kafka/consumer/group.py
@@ -1174,6 +1174,8 @@ class KafkaConsumer(six.Iterator):
         return self
 
     def __next__(self):
+        if self._closed:
+            raise StopIteration('KafkaConsumer closed')
         # Now that the heartbeat thread runs in the background
         # there should be no reason to maintain a separate iterator
         # but we'll keep it available for a few releases just in case
-- 
cgit v1.2.1