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/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'src/test/kotlin')

diff --git a/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt b/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt
index ff5b1ae..411c51e 100644
--- a/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt
+++ b/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt
@@ -101,7 +101,7 @@ class KafkaMtbFileSenderTest {
         val captor = argumentCaptor<String>()
         verify(kafkaTemplate, times(1)).send(anyString(), captor.capture(), captor.capture())
         assertThat(captor.firstValue).isNotNull
-        assertThat(captor.firstValue).isEqualTo("{\"pid\": \"PID\", \"eid\": \"1\"}")
+        assertThat(captor.firstValue).isEqualTo("{\"pid\": \"PID\"}")
         assertThat(captor.secondValue).isNotNull
         assertThat(captor.secondValue).isEqualTo(objectMapper.writeValueAsString(kafkaRecordData("TestID", Consent.Status.ACTIVE)))
     }
-- 
cgit v1.2.3