From 66635409d9a3c3500fce8a16f4ffe064f52bb1cc Mon Sep 17 00:00:00 2001
From: Yang Yang <yang.yang@fgrovep.com>
Date: Tue, 2 Jul 2024 20:36:37 +0000
Subject: [PATCH] Remove duplicate error log during rebalance

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 36d79c10..78a45ebd 100644
--- a/aiokafka/consumer/group_coordinator.py
+++ b/aiokafka/consumer/group_coordinator.py
@@ -1133,14 +1133,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: