diff options
author | Dana Powers <dana.powers@gmail.com> | 2018-03-10 13:29:39 -0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-03-10 13:29:39 -0500 |
commit | 8bdbe9264850add9c4c272540d9e2e5970e205dd (patch) | |
tree | 8a613a9dc5f27ee6804daf552fe75f057817c76d | |
parent | ec9049c60794785ab6c7babc90759678e665ccd8 (diff) | |
download | kafka-python-8bdbe9264850add9c4c272540d9e2e5970e205dd.tar.gz |
Remove old CommitFailed error message from coordinator (#1436)
-rw-r--r-- | kafka/coordinator/consumer.py | 12 |
1 files changed, 1 insertions, 11 deletions
diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 9076f61..cb1de0d 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -668,17 +668,7 @@ class ConsumerCoordinator(BaseCoordinator): log.debug("OffsetCommit for group %s failed: %s", self.group_id, error) self.reset_generation() - future.failure(Errors.CommitFailedError( - "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 session_timeout_ms, which typically" - " implies that the poll loop is spending too much time" - " message processing. You can address this either by" - " increasing the session timeout or by reducing the" - " maximum size of batches returned in poll() with" - " max_poll_records.")) + future.failure(Errors.CommitFailedError()) return else: log.error("Group %s failed to commit partition %s at offset" |