From 7ced45b3d6499863b8cc18193b08e8e362e466e4 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 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(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 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) {
-- 
cgit v1.2.3