From dedcec4ad59462b97531e498e8e388688bd0b8b1 Mon Sep 17 00:00:00 2001
From: Paul-Christian Volkmer
Date: Fri, 31 Oct 2025 16:54:33 +0100
Subject: fix: only send nested content with MTB record (#175)

---
 src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt   | 2 +-
 .../kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt    | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

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 d45fc51..ef46c0a 100644
--- a/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt
+++ b/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt
@@ -46,7 +46,7 @@ class KafkaMtbFileSender(
                     ProducerRecord(
                         kafkaProperties.outputTopic,
                         key(request),
-                        objectMapper.writeValueAsString(request),
+                        objectMapper.writeValueAsString(request.content),
                     )
                 record.headers().add("requestId", request.requestId.value.toByteArray())
                 when (request) {
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 d13d5e1..022b8dd 100644
--- a/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt
+++ b/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt
@@ -224,8 +224,8 @@ class KafkaMtbFileSenderTest {
             }
         }
 
-        fun dnmpV2kafkaRecordData(requestId: RequestId): MtbRequest {
-            return DnpmV2MtbFileRequest(requestId, dnpmV2MtbFile())
+        fun dnmpV2kafkaRecordData(requestId: RequestId): Mtb {
+            return DnpmV2MtbFileRequest(requestId, dnpmV2MtbFile()).content
         }
 
         data class TestData(val requestStatus: RequestStatus, val exception: Throwable? = null)
-- 
cgit v1.2.3