From 3651618825eaabf30f03164f6ded8b85c63860e8 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 15 Mar 2026 11:01:00 +0100
Subject: [PATCH] =?utf8?q?Stand=20der=20erarbeiteten=20L=C3=B6sung=20f?=
 =?utf8?q?=C3=BCr=20die=20=C3=9Cbung=20"Fire=20&=20Forget"?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 .../java/de/juplo/kafka/ExampleProducer.java  | 26 +++++++++++--------
 1 file changed, 15 insertions(+), 11 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 1cf50a6a..08a4bc3c 100644
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -25,15 +25,15 @@ public class ExampleProducer
     String topic,
     String clientId)
   {
-    // TODO:
-    // Instanziierung des KafkaProducer aus Ihrer bisherigen Implementierung
-    // Hier:
-    // - Den Parameter "broker" des Konstruktors für "bootstrap.servers" verwenden
-    // - Den Parameter "topic" des Konstruktors im Attribut "this.topic" merken
-    // - Den erzeugten KafkaProducer in "this.producer" ablegen
+    Properties props = new Properties();
+    props.put("bootstrap.servers", broker);
+    props.put("client.id", clientId); // Nur zur Wiedererkennung
+    props.put("key.serializer", StringSerializer.class.getName());
+    props.put("value.serializer", StringSerializer.class.getName());
 
     this.id = clientId;
     this.topic = topic;
+    producer = new KafkaProducer<>(props);
   }
 
   public void run()
@@ -44,11 +44,15 @@ public class ExampleProducer
     {
       for (; running; i++)
       {
-        // Versenden der Nachrichten aus Ihrer bisherigen Implementierung
-        // Hier:
-        // - ACHTUNG: Schreiben Sie in das Topic "this.topic"
-        // - Ergänzen Sie mit "log.info()" eine Log-Meldung, die gesendete Nachrichten ausgibt
-        // - Zählen Sie außerdem die versendeten Nachrichten in "this.produced"
+        final ProducerRecord<String, String> record = new ProducerRecord<>(
+          topic,               // Topic
+          Long.toString(i%10), // Key
+          Long.toString(i)     // Value
+        );
+
+        producer.send(record);
+
+        produced++;
       }
     }
     catch (Exception e)
-- 
2.39.5