diff options
| author | Paul-Christian Volkmer | 2024-03-09 10:58:03 +0100 |
|---|---|---|
| committer | Paul-Christian Volkmer | 2024-03-09 10:58:03 +0100 |
| commit | 299bd56d637ed720cf81a30536fdb8fb7af6f8f5 (patch) | |
| tree | fce917244941c2ba07be95c8378d18a1860fb1dc /src/main/kotlin/dev/dnpm | |
| parent | a0c4d1863f8b894d1e2937d1e4b2c2130dce0349 (diff) | |
feat: do not use episode id in kafka record key
Diffstat (limited to 'src/main/kotlin/dev/dnpm')
| -rw-r--r-- | src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt | 3 |
1 files changed, 1 insertions, 2 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 09edd31..fc5d617 100644 --- a/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt +++ b/src/main/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSender.kt @@ -94,8 +94,7 @@ class KafkaMtbFileSender( } private fun key(request: MtbFileSender.MtbFileRequest): String { - return "{\"pid\": \"${request.mtbFile.patient.id}\", " + - "\"eid\": \"${request.mtbFile.episode.id}\"}" + return "{\"pid\": \"${request.mtbFile.patient.id}\"}" } private fun key(request: MtbFileSender.DeleteRequest): String { |