Additional docstrings for autocommit close option

2 files changed, 10 insertions, 2 deletions

diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
index ab259dd..85b1d78 100644
--- a/kafka/coordinator/base.py
+++ b/kafka/coordinator/base.py
@@ -538,8 +538,8 @@ class BaseCoordinator(object):
             self.coordinator_id = None
 
     def close(self):
-        """Close the coordinator, leave the current group
-        and reset local generation/memberId."""
+        """Close the coordinator, leave the current group,
+        and reset local generation / member_id"""
         try:
             self._client.unschedule(self.heartbeat_task)
         except KeyError:
diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py
index fdbb995..00b8b6b 100644
--- a/kafka/coordinator/consumer.py
+++ b/kafka/coordinator/consumer.py
@@ -326,6 +326,14 @@ class ConsumerCoordinator(BaseCoordinator):
             time.sleep(self.config['retry_backoff_ms'] / 1000.0)
 
     def close(self, autocommit=True):
+        """Close the coordinator, leave the current group,
+        and reset local generation / member_id.
+
+        Keyword Arguments:
+            autocommit (bool): If auto-commit is configured for this consumer,
+                this optional flag causes the consumer to attempt to commit any
+                pending consumed offsets prior to close. Default: True
+        """
         try:
             if autocommit:
                 self._maybe_auto_commit_offsets_sync()