From 22e65d37e46c7119bb3a178f538173296149c555 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  | 23 ++++++++++++-------
 1 file changed, 15 insertions(+), 8 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index ad713726..5589c358 100644
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -25,14 +25,15 @@ public class ExampleProducer
     String topic,
     String clientId)
   {
-    // TODO:
-    // Instanziierung des KafkaProducer aus Ihrer bisherigen Implementierung
-    // Hier:
-    // - Instanz in this.producer ablegen
-    // - Das Attribut broker des Konstruktors für bootstrap.servers verwenden
+    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()
@@ -43,9 +44,15 @@ public class ExampleProducer
     {
       for (; running; i++)
       {
-        // Versenden der Nachrichten aus Ihrer bisherigen Implementierung
-        // Hier:
-        // - 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