diff options
Diffstat (limited to 'kafka/consumer/kafka.py')
| -rw-r--r-- | kafka/consumer/kafka.py | 4 |
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 |