From: Kai Moritz <kai@juplo.de>
Date: Sun, 11 Jun 2023 21:13:45 +0000 (+0200)
Subject: Implementierung der Header entfernt - Übung kommt jetzt später
X-Git-Tag: producer/rest-producer--headers---2023-06-signal~6
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=104ee765368f89bcb0209fbdf01df4ec4c88cf0f;p=demos%2Fkafka%2Ftraining

Implementierung der Header entfernt - Übung kommt jetzt später
---

diff --git a/src/main/java/de/juplo/kafka/RestProducer.java b/src/main/java/de/juplo/kafka/RestProducer.java
index cecb980..73bec5b 100644
--- a/src/main/java/de/juplo/kafka/RestProducer.java
+++ b/src/main/java/de/juplo/kafka/RestProducer.java
@@ -42,12 +42,6 @@ public class RestProducer
         value   // Value
     );
 
-    record.headers().add("source", id.getBytes());
-    if (correlationId != null)
-    {
-      record.headers().add("id", BigInteger.valueOf(correlationId).toByteArray());
-    }
-
     producer.send(record, (metadata, e) ->
     {
       long now = System.currentTimeMillis();