From: Kai Moritz <kai@juplo.de>
Date: Sat, 12 Nov 2022 10:20:40 +0000 (+0100)
Subject: Konfiguration so weit wie möglich vereinfacht
X-Git-Tag: supersimple-producer---lvm-2-tage--easy-path~5
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=0cf4b667026edf0587cc7a8c9698a025e112b600;p=demos%2Fkafka%2Ftraining

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
--- 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
--- 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