From 2c9afde8c6b8d465eb65119a123dca62306ec0c8 Mon Sep 17 00:00:00 2001 From: Ilayaperumal Gopinathan Date: Thu, 11 May 2017 23:37:38 +0530 Subject: [PATCH] Remove log format setting in KafakEnvironmentPostProcessor Resolves #132 --- .../stream/binder/kafka/KafkaBinderEnvironmentPostProcessor.java | 1 - 1 file changed, 1 deletion(-) diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderEnvironmentPostProcessor.java b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderEnvironmentPostProcessor.java index 0e24318b1..30e1c1e5f 100644 --- a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderEnvironmentPostProcessor.java +++ b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderEnvironmentPostProcessor.java @@ -55,7 +55,6 @@ public class KafkaBinderEnvironmentPostProcessor implements EnvironmentPostProce public void postProcessEnvironment(ConfigurableEnvironment environment, SpringApplication application) { if (!environment.getPropertySources().contains(KAFKA_BINDER_DEFAULT_PROPERTIES)) { Map kafkaBinderDefaultProperties = new HashMap<>(); - kafkaBinderDefaultProperties.put("logging.pattern.console", "%d{ISO8601} %5p %t %c{2}:%L - %m%n"); kafkaBinderDefaultProperties.put("logging.level.org.I0Itec.zkclient", "ERROR"); kafkaBinderDefaultProperties.put("logging.level.kafka.server.KafkaConfig", "ERROR"); kafkaBinderDefaultProperties.put("logging.level.kafka.admin.AdminClient.AdminConfig", "ERROR");