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