From c2de4caf806bcf8cd27c31accc0e6535b7b57b84 Mon Sep 17 00:00:00 2001 From: Akshay Philar Date: Tue, 8 May 2018 19:59:01 +0530 Subject: [PATCH] suppressing noisy heartbeat log message --- kafka/coordinator/base.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 7deeaf05d..d31fccfdf 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -974,7 +974,7 @@ def _run_once(self): 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.log(0, 'Not ready to heartbeat, waiting') + # log.log(0, 'Not ready to heartbeat, waiting') with self.coordinator._lock: self.coordinator._lock.wait(self.coordinator.config['retry_backoff_ms'] / 1000)