From f18fd757e1d08172cd350bb278f01f26f19e5817 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 22 Mar 2018 14:42:49 -0700 Subject: Change levels for some heartbeat thread logging --- kafka/coordinator/base.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 9f67d6b..7d60234 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -956,20 +956,20 @@ class HeartbeatThread(threading.Thread): # the session timeout has expired without seeing a # successful heartbeat, so we should probably make sure # the coordinator is still healthy. - log.debug('Heartbeat session expired, marking coordinator dead') + log.warning('Heartbeat session expired, marking coordinator dead') self.coordinator.coordinator_dead('Heartbeat session expired') elif self.coordinator.heartbeat.poll_timeout_expired(): # the poll timeout has expired, which means that the # foreground thread has stalled in between calls to # poll(), so we explicitly leave the group. - log.debug('Heartbeat poll expired, leaving group') + log.warning('Heartbeat poll expired, leaving group') self.coordinator.maybe_leave_group() elif not self.coordinator.heartbeat.should_heartbeat(): # poll again after waiting for the retry backoff in case # the heartbeat failed or the coordinator disconnected - log.debug('Not ready to heartbeat, waiting') + log.log(0, 'Not ready to heartbeat, waiting') self.coordinator._lock.wait(self.coordinator.config['retry_backoff_ms'] / 1000) else: -- cgit v1.2.1