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

dpkp · dpkp · commit 89ea42af4545 · 2015-12-06T16:08:47.000-08:00
Add KafkaConsumer#close
diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py
@@ -269,6 +269,10 @@ def set_topic_partitions(self, *topics):
         # 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
 
