Remove duplicate error log during rebalance (#1025)

This log message is emitted twice.
aio-libs · Oct 26, 2024 · f7861f6 · f7861f6
1 parent e7c9033
commit f7861f6
Showing 1 changed file with 0 additions and 8 deletions.
diff --git 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: