From e4dd59e8f2c3ce1633813fb59a3a5faf90bbfabd Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 16 Sep 2020 22:27:49 +0200 Subject: [PATCH] WIP --- src/main/java/de/juplo/kafka/outbox/polling/OutboxListener.java | 2 ++ src/main/resources/application.properties | 1 + 2 files changed, 3 insertions(+) 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 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 -- 2.20.1