From ad024d1e897dbf16bd629fa63895bd7af4a8d959 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 21 Dec 2017 14:46:10 -0800 Subject: KAFKA-3888 Use background thread to process consumer heartbeats (#1266) --- kafka/errors.py | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) (limited to 'kafka/errors.py') 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): -- cgit v1.2.1