KAFKA-3888 Use background thread to process consumer heartbeats (#1266)

1 files changed, 12 insertions, 1 deletions

diff --git a/kafka/errors.py b/kafka/errors.py
index 4a409db..c70853c 100644
--- a/kafka/errors.py
+++ b/kafka/errors.py
@@ -59,7 +59,18 @@ class UnrecognizedBrokerVersion(KafkaError):
 
 
 class CommitFailedError(KafkaError):
-    pass
+    def __init__(self, *args, **kwargs):
+        super(CommitFailedError, self).__init__(
+            """Commit cannot be completed since the group has already
+            rebalanced and assigned the partitions to another member.
+            This means that the time between subsequent calls to poll()
+            was longer than the configured max_poll_interval_ms, which
+            typically implies that the poll loop is spending too much
+            time message processing. You can address this either by
+            increasing the rebalance timeout with max_poll_interval_ms,
+            or by reducing the maximum size of batches returned in poll()
+            with max_poll_records.
+            """, *args, **kwargs)
 
 
 class AuthenticationMethodNotSupported(KafkaError):