From: Kai Moritz <kai@juplo.de>
Date: Wed, 16 Sep 2020 20:27:49 +0000 (+0200)
Subject: WIP
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=refs%2Fheads%2Fkafka;p=demos%2Fkafka%2Foutbox

WIP
---

diff --git a/src/main/java/de/juplo/kafka/outbox/polling/OutboxListener.java b/src/main/java/de/juplo/kafka/outbox/polling/OutboxListener.java
index 5b731a2..d6ac91a 100644
--- a/src/main/java/de/juplo/kafka/outbox/polling/OutboxListener.java
+++ b/src/main/java/de/juplo/kafka/outbox/polling/OutboxListener.java
@@ -63,6 +63,8 @@ public class OutboxListener {
                 String username = (String)entry.get("username");
                 String event = username + ":" + type.name();
 
+                LOG.debug("Sending event {} ({})", id, event);
+
                 ProducerRecord<Long, String> record = new ProducerRecord<>(topic, id, event);
                 producer.send(record, (metadata, e) -> {
                     if (e != null) {
diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
index 821da09..5b876fd 100644
--- a/src/main/resources/application.properties
+++ b/src/main/resources/application.properties
@@ -1 +1,2 @@
 management.endpoints.web.exposure.include=*
+logging.level.de.juplo=DEBUG