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 5b731a254eb9e348f0d699b7c234c21032a2f273..d6ac91ab955e78ac3f63047a5c17e16dd0a9979f 100644 (file)
--- 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 821da092741ec8dde91db57573bcd9e149532016..5b876fdc196ba3c66c330cb8b08f5fd133d0980b 100644 (file)
--- 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