From 2b3218845893ebcc7e506563c8fa57fc6d7aab84 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Mon, 1 Aug 2022 22:40:27 +0200
Subject: [PATCH] Vorlage

---
 pom.xml                                       |  4 --
 .../java/de/juplo/kafka/SimpleProducer.java   | 52 ++++---------------
 2 files changed, 11 insertions(+), 45 deletions(-)

diff --git a/pom.xml b/pom.xml
index 4c52f37..9bd2418 100644
--- a/pom.xml
+++ b/pom.xml
@@ -33,10 +33,6 @@
 
   <build>
     <plugins>
-      <plugin>
-        <groupId>pl.project13.maven</groupId>
-        <artifactId>git-commit-id-plugin</artifactId>
-      </plugin>
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-dependency-plugin</artifactId>
diff --git a/src/main/java/de/juplo/kafka/SimpleProducer.java b/src/main/java/de/juplo/kafka/SimpleProducer.java
index db554d7..9a9e6c2 100644
--- a/src/main/java/de/juplo/kafka/SimpleProducer.java
+++ b/src/main/java/de/juplo/kafka/SimpleProducer.java
@@ -23,10 +23,7 @@ public class SimpleProducer
   public SimpleProducer(String broker, String topic, String clientId)
   {
     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());
+    // TODO: Konfiguration für den Producer zusammenstellen
 
     this.id = clientId;
     this.topic = topic;
@@ -59,43 +56,16 @@ public class SimpleProducer
   {
     final long time = System.currentTimeMillis();
 
-    final ProducerRecord<String, String> record = new ProducerRecord<>(
-        topic,  // Topic
-        key,    // Key
-        value   // Value
-    );
-
-    producer.send(record, (metadata, e) ->
-    {
-      long now = System.currentTimeMillis();
-      if (e == null)
-      {
-        // HANDLE SUCCESS
-        produced++;
-        log.debug(
-            "{} - Sent key={} message={} partition={}/{} timestamp={} latency={}ms",
-            id,
-            record.key(),
-            record.value(),
-            metadata.partition(),
-            metadata.offset(),
-            metadata.timestamp(),
-            now - time
-        );
-      }
-      else
-      {
-        // HANDLE ERROR
-        log.error(
-            "{} - ERROR key={} timestamp={} latency={}ms: {}",
-            id,
-            record.key(),
-            metadata == null ? -1 : metadata.timestamp(),
-            now - time,
-            e.toString()
-        );
-      }
-    });
+    ProducerRecord<String, String> record = null;
+    // TODO:
+    //
+    // 1. ProducerRecord<String, String> erzeugen
+    // 2. Record mit producer.send(...) verschicken
+    // Dabei beachten:
+    // * Callback implementieren und Erfolg/Fehler logge
+    // * Tipp: Aktuellen Zeitstempel auch im Callback erzeugen und
+    //   Millisekunden berechnen, die bis zum Senden verstrichen sind:
+    //   long now = System.currentTimeMillis(); // Für: now - time
 
     long now = System.currentTimeMillis();
     log.trace(
-- 
2.20.1