diff options
| author | Dana Powers <dana.powers@rd.io> | 2018-03-10 11:14:14 -0500 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2018-03-10 11:14:14 -0500 |
| commit | e9393e2a131c5703fca686379b785a20ae6c945d (patch) | |
| tree | f784b80f8e47b7866b4b16b2ad4a659cf669f191 | |
| parent | 1ffdd5caf7f10fb5372780cb9a5ac4a906cac342 (diff) | |
| download | kafka-python-commit_failed_message_fixup.tar.gz | |
Remove old CommitFailed error message from coordinatorcommit_failed_message_fixup
| -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" |