diff options
| author | Paul-Christian Volkmer | 2024-03-09 11:00:28 +0100 |
|---|---|---|
| committer | GitHub | 2024-03-09 11:00:28 +0100 |
| commit | f751d642207b590841a3be8a861875dfa2f55bc1 (patch) | |
| tree | fce917244941c2ba07be95c8378d18a1860fb1dc /src/test/kotlin/dev/dnpm | |
| parent | a0c4d1863f8b894d1e2937d1e4b2c2130dce0349 (diff) | |
| parent | 299bd56d637ed720cf81a30536fdb8fb7af6f8f5 (diff) | |
Merge pull request #59 from CCC-MF/issue_58
feat: do not use episode id in kafka record key
Diffstat (limited to 'src/test/kotlin/dev/dnpm')
| -rw-r--r-- | src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt | 2 |
1 files changed, 1 insertions, 1 deletions
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 ff5b1ae..411c51e 100644 --- a/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt +++ b/src/test/kotlin/dev/dnpm/etl/processor/output/KafkaMtbFileSenderTest.kt @@ -101,7 +101,7 @@ class KafkaMtbFileSenderTest { val captor = argumentCaptor<String>() verify(kafkaTemplate, times(1)).send(anyString(), captor.capture(), captor.capture()) assertThat(captor.firstValue).isNotNull - assertThat(captor.firstValue).isEqualTo("{\"pid\": \"PID\", \"eid\": \"1\"}") + assertThat(captor.firstValue).isEqualTo("{\"pid\": \"PID\"}") assertThat(captor.secondValue).isNotNull assertThat(captor.secondValue).isEqualTo(objectMapper.writeValueAsString(kafkaRecordData("TestID", Consent.Status.ACTIVE))) } |