From 0262d87e7c7f1557355d64f6073d80b328016d6c Mon Sep 17 00:00:00 2001 From: Johnny Lim Date: Tue, 19 Dec 2017 00:25:43 +0900 Subject: [PATCH] Remove unnecessary logging guards --- .../kafka/listener/KafkaMessageListenerContainer.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java index 7eaa064e..d40b2aff 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java @@ -699,9 +699,7 @@ public class KafkaMessageListenerContainer extends AbstractMessageListener ((ThreadPoolTaskScheduler) this.taskScheduler).destroy(); } this.consumer.close(); - if (this.logger.isInfoEnabled()) { - this.logger.info("Consumer stopped"); - } + this.logger.info("Consumer stopped"); } private void commitPendingAcks() { @@ -1211,9 +1209,7 @@ public class KafkaMessageListenerContainer extends AbstractMessageListener } catch (WakeupException e) { // ignore - not polling - if (this.logger.isDebugEnabled()) { - this.logger.debug("Woken up during commit"); - } + this.logger.debug("Woken up during commit"); } } }