Add KafkaConsumer#close

1 files changed, 4 insertions, 0 deletions

diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py
index 11c4221..efe9105 100644
--- a/kafka/consumer/kafka.py
+++ b/kafka/consumer/kafka.py
@@ -268,6 +268,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