Skip to content

Commit 452e354

Browse files
committed
Log all SyncGroupResponse errors as info+
1 parent 5de666a commit 452e354

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

kafka/coordinator/base.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -723,19 +723,19 @@ def _handle_sync_group_response(self, future, send_time, response):
723723
if error_type is Errors.GroupAuthorizationFailedError:
724724
future.failure(error_type(self.group_id))
725725
elif error_type is Errors.RebalanceInProgressError:
726-
log.debug("SyncGroup for group %s failed due to coordinator"
727-
" rebalance", self.group_id)
726+
log.info("SyncGroup for group %s failed due to coordinator"
727+
" rebalance", self.group_id)
728728
future.failure(error_type(self.group_id))
729729
elif error_type in (Errors.UnknownMemberIdError,
730730
Errors.IllegalGenerationError):
731731
error = error_type()
732-
log.debug("SyncGroup for group %s failed due to %s", self.group_id, error)
732+
log.info("SyncGroup for group %s failed due to %s", self.group_id, error)
733733
self.reset_generation()
734734
future.failure(error)
735735
elif error_type in (Errors.CoordinatorNotAvailableError,
736736
Errors.NotCoordinatorError):
737737
error = error_type()
738-
log.debug("SyncGroup for group %s failed due to %s", self.group_id, error)
738+
log.info("SyncGroup for group %s failed due to %s", self.group_id, error)
739739
self.coordinator_dead(error)
740740
future.failure(error)
741741
else:

0 commit comments

Comments
 (0)