WIP

[demos/kafka/outbox] / src / main / java / de / juplo / kafka / outbox / polling / OutboxListener.java

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) {