diff options
Diffstat (limited to 'kafka/coordinator/consumer.py')
| -rw-r--r-- | kafka/coordinator/consumer.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index a600cb4..fac8144 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -525,7 +525,7 @@ class ConsumerCoordinator(BaseCoordinator): Errors.RequestTimedOutError): log.debug("OffsetCommit for group %s failed: %s", self.group_id, error_type.__name__) - self.coordinator_dead() + self.coordinator_dead(error_type()) future.failure(error_type(self.group_id)) return elif error_type in (Errors.UnknownMemberIdError, @@ -630,7 +630,7 @@ class ConsumerCoordinator(BaseCoordinator): future.failure(error) elif error_type is Errors.NotCoordinatorForGroupError: # re-discover the coordinator and retry - self.coordinator_dead() + self.coordinator_dead(error_type()) future.failure(error) elif error_type in (Errors.UnknownMemberIdError, Errors.IllegalGenerationError): |