From 0cf4b667026edf0587cc7a8c9698a025e112b600 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 12 Nov 2022 11:20:40 +0100
Subject: [PATCH] =?utf8?q?Konfiguration=20so=20weit=20wie=20m=C3=B6glich?=
 =?utf8?q?=20vereinfacht?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

* 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.
---
 src/main/java/de/juplo/kafka/Application.java | 2 +-
 src/main/resources/application.yml            | 3 ---
 2 files changed, 1 insertion(+), 4 deletions(-)

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