Logging-Level auf INFO geändert, damit die Logging-Konfig nicht nötig ist

[demos/kafka/training] / src / main / java / de / juplo / kafka / Application.java

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index 91b157a..9781a7a 100644 (file)
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -23,10 +23,10 @@ public class Application implements ApplicationRunner
   void send(String key, String value)
   {
     ListenableFuture<SendResult<String, String>> listenableFuture =
-        kafkaTemplate.sendDefault(key, value);
+        kafkaTemplate.send("test", key, value);
 
     listenableFuture.addCallback(
-        result -> log.debug(
+        result -> log.info(
             "Sent {}={} to partition={}, offset={}",
             result.getProducerRecord().key(),
             result.getProducerRecord().value(),