diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-03-22 14:42:49 -0700 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2018-03-23 13:54:12 -0700 |
| commit | f18fd757e1d08172cd350bb278f01f26f19e5817 (patch) | |
| tree | 2d206143f7f1909b653b3e5775c7317021f637d5 | |
| parent | c0fddbd24269d4333e3b6630a23e86ffe33dfcb6 (diff) | |
| download | kafka-python-f18fd757e1d08172cd350bb278f01f26f19e5817.tar.gz | |
Change levels for some heartbeat thread logging
| -rw-r--r-- | kafka/coordinator/base.py | 6 |
1 files 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: |