diff --git a/pkg/kafka/sarama_client.go b/pkg/kafka/sarama_client.go
index edb57ad..99168dc 100755
--- a/pkg/kafka/sarama_client.go
+++ b/pkg/kafka/sarama_client.go
@@ -474,7 +474,7 @@
 			sc.liveness <- alive
 			sc.lastLivenessTime = time.Now()
 		} else if time.Since(sc.lastLivenessTime) > sc.livenessChannelInterval {
-			logger.Info(ctx, "update-liveness-channel-because-interval")
+			logger.Debugf(ctx, "update-liveness-channel-because-interval")
 			sc.liveness <- alive
 			sc.lastLivenessTime = time.Now()
 		}
diff --git a/pkg/kafka/utils.go b/pkg/kafka/utils.go
index 7dcc724..fba621f 100644
--- a/pkg/kafka/utils.go
+++ b/pkg/kafka/utils.go
@@ -170,7 +170,7 @@
 				<-timeoutTimer.C
 			}
 		case <-timeoutTimer.C:
-			logger.Infow(ctx, "kafka-proxy-liveness-recheck", log.Fields{"service": serviceName})
+			logger.Debugf(ctx, "kafka-proxy-liveness-recheck", log.Fields{"service": serviceName})
 			// send the liveness probe in a goroutine; we don't want to deadlock ourselves as
 			// the liveness probe may wait (and block) writing to our channel.
 			go func() {