commit e56e3ff916e0fe433f540abc2992a25e7d5e8539
author Christian Schneider <cschneid@adobe.com> Mon Jan 13 18:09:54 2020 +0100
committer Christian Schneider <cschneid@adobe.com> Mon Jan 13 18:09:54 2020 +0100
tree fb6b2a988c8b00f5ecb4871df09f1847fb8ea865
parent 8345a59802ae13141fbf4863f948ee5877f8b22b

Only log sending messages at debug level

src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java

diff --git a/src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java b/src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java
index 69defdc..e3a434d 100644
--- a/src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java
+++ b/src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java
@@ -64,7 +64,7 @@
         ProducerRecord<String, byte[]> record = new ProducerRecord<>(topic, PARTITION, null, null, payload.toByteArray(), toHeaders(type, version));
         try {
             RecordMetadata metadata = producer.send(record).get();
-            LOG.info("Sent to {}", metadata);
+            LOG.debug("Sent to {}", metadata);
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
             handleException(topic, e);