From 9134e101dfc3427b61ead3723ada1fbf62be8de2 Mon Sep 17 00:00:00 2001 From: Tom Ellis Date: Sat, 22 Jul 2017 12:16:43 +0800 Subject: [PATCH] Remove duplicate debug statement. unless you really really want to make sure users see this :) --- .../cloud/stream/binder/kafka/KafkaMessageChannelBinder.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java index be6263ecf..8dff0370a 100644 --- a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java +++ b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java @@ -282,10 +282,6 @@ public class KafkaMessageChannelBinder extends this.logger.debug( "Listened partitions: " + StringUtils.collectionToCommaDelimitedString(listenedPartitions)); } - if (this.logger.isDebugEnabled()) { - this.logger.debug( - "Listened partitions: " + StringUtils.collectionToCommaDelimitedString(listenedPartitions)); - } final KafkaMessageDrivenChannelAdapter kafkaMessageDrivenChannelAdapter = new KafkaMessageDrivenChannelAdapter<>( messageListenerContainer); kafkaMessageDrivenChannelAdapter.setBeanFactory(this.getBeanFactory());