X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplication.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplication.java;h=9781a7a02b051a4e8f16c5539b68de309c7bfe41;hb=057035f073b7f6db51efaab88d40fec1bd895482;hp=944a7a72bb8ad03674d225fcd55a75a9a4942104;hpb=0cf4b667026edf0587cc7a8c9698a025e112b600;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index 944a7a7..9781a7a 100644
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -26,7 +26,7 @@ public class Application implements ApplicationRunner
         kafkaTemplate.send("test", key, value);
 
     listenableFuture.addCallback(
-        result -> log.debug(
+        result -> log.info(
             "Sent {}={} to partition={}, offset={}",
             result.getProducerRecord().key(),
             result.getProducerRecord().value(),