You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by cs...@apache.org on 2020/01/13 17:10:12 UTC
[sling-org-apache-sling-distribution-journal-kafka] branch master
updated: Only log sending messages at debug level
This is an automated email from the ASF dual-hosted git repository.
cschneider pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal-kafka.git
The following commit(s) were added to refs/heads/master by this push:
new e56e3ff Only log sending messages at debug level
e56e3ff is described below
commit e56e3ff916e0fe433f540abc2992a25e7d5e8539
Author: Christian Schneider <cs...@adobe.com>
AuthorDate: Mon Jan 13 18:09:54 2020 +0100
Only log sending messages at debug level
---
.../org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 @@ public class KafkaMessageSender<T extends GeneratedMessage> implements MessageSe
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);