From 3346f1ec39eff5a78802a78e78d3f1d652f7b3ae Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Sebastian=20Sch=C3=BCpbach?=
 <sebastian.schuepbach@unibas.ch>
Date: Thu, 7 Jan 2021 16:13:07 +0100
Subject: [PATCH] copy message key from consumed to produced record
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: Sebastian Schüpbach <sebastian.schuepbach@unibas.ch>
---
 src/main/kotlin/KafkaTopology.kt | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/kotlin/KafkaTopology.kt b/src/main/kotlin/KafkaTopology.kt
index 6da8928..3d51624 100644
--- a/src/main/kotlin/KafkaTopology.kt
+++ b/src/main/kotlin/KafkaTopology.kt
@@ -111,7 +111,7 @@ class KafkaTopology(
                     }
 
                     var producerRecord: ProducerRecord<String, String> =
-                        ProducerRecord(outputTopic, event.eventId, modelString)
+                        ProducerRecord(outputTopic, it.key(), modelString)
                     if (headerData.containsKey("institutionId")) {
                         producerRecord.headers().add("institutionId", headerData["institutionId"]?.toByteArray())
                     }
-- 
GitLab