diff options
| -rw-r--r-- | src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt | 2 | ||||
| -rw-r--r-- | src/test/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) |