Konfiguration so weit wie möglich vereinfacht

* Damit das Default-Topic nicht gesetzt werden muss, muss das Topic
  jetzt im `send()`-Aufruf explizit angegeben werden. Das ist aber
  eigentlich für das Beispiel eh verständlicher.
* Die Logging-Konfiguration wird benötigt, da ansonsten in der Ausgabe
  nicht ersichtlich ist, dass der Producer die Nachrichten erfolgreich
  versendet hat.

diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java
index 91b157a..944a7a7 100644 (file)
--- a/src/main/java/de/juplo/kafka/Application.java
+++ b/src/main/java/de/juplo/kafka/Application.java
@@ -23,7 +23,7 @@ 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(

diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index ac58386..a6bb65e 100644 (file)
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -1,9 +1,6 @@
 spring:
   kafka:
     bootstrap-servers: :9092
-    client-id: DEV
-    template:
-      default-topic: test
 logging:
   level:
     root: INFO