From 299bd56d637ed720cf81a30536fdb8fb7af6f8f5 Mon Sep 17 00:00:00 2001
From: Paul-Christian Volkmer
Date: Sat, 9 Mar 2024 10:58:03 +0100
Subject: feat: do not use episode id in kafka record key

---
 src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

(limited to 'src/main/kotlin')

diff --git a/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt b/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt
index 09edd31..fc5d617 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt
@@ -94,8 +94,7 @@ class KafkaMtbFileSender(
     }
 
     private fun key(request: MtbFileSender.MtbFileRequest): String {
-        return "{\"pid\": \"${request.mtbFile.patient.id}\", " +
-                "\"eid\": \"${request.mtbFile.episode.id}\"}"
+        return "{\"pid\": \"${request.mtbFile.patient.id}\"}"
     }
 
     private fun key(request: MtbFileSender.DeleteRequest): String {
-- 
cgit v1.2.3