Merge pull request #426 from ucarion/ucarion-kafkaconsumer-close

Add KafkaConsumer#close

1 files changed, 4 insertions, 0 deletions

diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py
index 21b2bf6..3ef106c 100644
--- a/kafka/consumer/kafka.py
+++ b/kafka/consumer/kafka.py
@@ -269,6 +269,10 @@ class KafkaConsumer(object):
         # Reset message iterator in case we were in the middle of one
         self._reset_message_iterator()
 
+    def close(self):
+        """Close this consumer's underlying client."""
+        self._client.close()
+
     def next(self):
         """Return the next available message