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 (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 821da09..5b876fd 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