Skip to content

Commit f7861f6

Browse files
authored
Remove duplicate error log during rebalance (#1025)
This log message is emitted twice.
1 parent e7c9033 commit f7861f6

File tree

1 file changed

+0
-8
lines changed

1 file changed

+0
-8
lines changed

aiokafka/consumer/group_coordinator.py

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1130,14 +1130,6 @@ async def _do_commit_offsets(self, assignment, offsets):
11301130
self.request_rejoin()
11311131
else:
11321132
self.reset_generation()
1133-
# need to re-join group
1134-
error = error_type(self.group_id)
1135-
log.error(
1136-
"OffsetCommit failed for group %s due to group"
1137-
" error (%s), will rejoin",
1138-
self.group_id,
1139-
error,
1140-
)
11411133
errored[tp] = error
11421134

11431135
else:

0 commit comments

Comments
 (0)