diff options
| author | Paul-Christian Volkmer | 2025-10-31 16:54:33 +0100 |
|---|---|---|
| committer | GitHub | 2025-10-31 16:54:33 +0100 |
| commit | 7ced45b3d6499863b8cc18193b08e8e362e466e4 (patch) | |
| tree | 44f20da5cbf98934490e6e7fbf3c2e70df8425c7 /src/main/kotlin/dev/dnpm/etl/processor | |
| parent | 2cb2b60091405ca95c1f134f5d995e0fc30c908a (diff) | |
fix: only send nested content with MTB record (#175)
Diffstat (limited to 'src/main/kotlin/dev/dnpm/etl/processor')
| -rw-r--r-- | src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt | 2 |
1 files changed, 1 insertions, 1 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) { |