From f7861f682c9b5cd78411e7fd6ea0fc4bf92ded33 Mon Sep 17 00:00:00 2001 From: Yang Yang Date: Sat, 26 Oct 2024 11:13:40 -0400 Subject: [PATCH] Remove duplicate error log during rebalance (#1025) This log message is emitted twice. --- aiokafka/consumer/group_coordinator.py | 8 -------- 1 file changed, 8 deletions(-) diff --git a/aiokafka/consumer/group_coordinator.py b/aiokafka/consumer/group_coordinator.py index 06555675..4fd52538 100644 --- a/aiokafka/consumer/group_coordinator.py +++ b/aiokafka/consumer/group_coordinator.py @@ -1130,14 +1130,6 @@ async def _do_commit_offsets(self, assignment, offsets): self.request_rejoin() else: self.reset_generation() - # need to re-join group - error = error_type(self.group_id) - log.error( - "OffsetCommit failed for group %s due to group" - " error (%s), will rejoin", - self.group_id, - error, - ) errored[tp] = error else: