From: Kai Moritz <kai@juplo.de>
Date: Sat, 24 Sep 2022 17:56:15 +0000 (+0200)
Subject: Merge branch 'rest-producer' into rest-producer-vorlage
X-Git-Tag: rest-producer--vorlage---lvm-2-tage
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=03496360829d2b9401ca114f9fc8d64320fd72a6;hp=1cd2d60f29b44574a2b6ca99cb7eeafa78cb4c90;p=demos%2Fkafka%2Ftraining

Merge branch 'rest-producer' into rest-producer-vorlage
---

diff --git a/src/main/java/de/juplo/kafka/RestProducer.java b/src/main/java/de/juplo/kafka/RestProducer.java
index 0467118..009a1f2 100644
--- a/src/main/java/de/juplo/kafka/RestProducer.java
+++ b/src/main/java/de/juplo/kafka/RestProducer.java
@@ -41,47 +41,10 @@ public class RestProducer
         value   // Value
     );
 
-    producer.send(record, (metadata, e) ->
-    {
-      long now = System.currentTimeMillis();
-      if (e == null)
-      {
-        // HANDLE SUCCESS
-        produced++;
-        result.setResult(new ProduceSuccess(metadata.partition(), metadata.offset()));
-        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
-        result.setErrorResult(new ProduceFailure(e));
-        log.error(
-            "{} - ERROR key={} timestamp={} latency={}ms: {}",
-            id,
-            record.key(),
-            metadata == null ? -1 : metadata.timestamp(),
-            now - time,
-            e.toString()
-        );
-      }
-    });
-
-    long now = System.currentTimeMillis();
-    log.trace(
-        "{} - Queued message with key={} latency={}ms",
-        id,
-        record.key(),
-        now - time
-    );
+    // TODO: Nachricht versenden und Feedback geben
+    // Tipp:
+    // result.setResult(new ProduceSuccess(metadata.partition(), metadata.offset()));
+    // result.setErrorResult(new ProduceFailure(e));
 
     return result;
   }