Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove unnecessary logging guards

Browse Source
This commit is contained in:
Johnny Lim
2017-12-19 00:25:43 +09:00
committed by Artem Bilan
parent 185e982ef9
commit 0262d87e7c
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java
View File

@@ -699,9 +699,7 @@ public class KafkaMessageListenerContainer<K, V> 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<K, V> 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");
}
}
}