WIP kafka
authorKai Moritz <kai@juplo.de>
Wed, 16 Sep 2020 20:27:49 +0000 (22:27 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 24 Oct 2020 08:59:33 +0000 (10:59 +0200)
src/main/java/de/juplo/kafka/outbox/polling/OutboxListener.java
src/main/resources/application.properties

index 5b731a2..d6ac91a 100644 (file)
@@ -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) {
index 821da09..5b876fd 100644 (file)
@@ -1 +1,2 @@
 management.endpoints.web.exposure.include=*
+logging.level.de.juplo=DEBUG