From b47736dc26c28bd5446f6d4020944a3cbce5d83f Mon Sep 17 00:00:00 2001
From: Ulysse Carion <ulysse@ulysse.io>
Date: Tue, 7 Jul 2015 16:03:44 -0700
Subject: Add KafkaConsumer#close

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

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

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