We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 185e982 commit 0262d87Copy full SHA for 0262d87
spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java
@@ -699,9 +699,7 @@ public void run() {
699
((ThreadPoolTaskScheduler) this.taskScheduler).destroy();
700
}
701
this.consumer.close();
702
- if (this.logger.isInfoEnabled()) {
703
- this.logger.info("Consumer stopped");
704
- }
+ this.logger.info("Consumer stopped");
705
706
707
private void commitPendingAcks() {
@@ -1211,9 +1209,7 @@ private void commitIfNecessary() {
1211
1209
1212
1210
catch (WakeupException e) {
1213
// ignore - not polling
1214
- if (this.logger.isDebugEnabled()) {
1215
- this.logger.debug("Woken up during commit");
1216
+ this.logger.debug("Woken up during commit");
1217
1218
1219
0 commit comments