From 104ee765368f89bcb0209fbdf01df4ec4c88cf0f Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 11 Jun 2023 23:13:45 +0200
Subject: [PATCH] =?utf8?q?Implementierung=20der=20Header=20entfernt=20-=20?=
 =?utf8?q?=C3=9Cbung=20kommt=20jetzt=20sp=C3=A4ter?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 src/main/java/de/juplo/kafka/RestProducer.java | 6 ------
 1 file changed, 6 deletions(-)

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();
-- 
2.20.1