Add session id to key (otherwise it is not unique ...)

14799e2e · Jonas Waeber · ed91bcab · 14799e2e
Commit 14799e2e authored Aug 17, 2021 by Jonas Waeber
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

src/main/kotlin/KafkaTopology.kt src/main/kotlin/KafkaTopology.kt +1 -1

No files found.
--- a/src/main/kotlin/KafkaTopology.kt
+++ b/src/main/kotlin/KafkaTopology.kt
@@ -55,7 +55,7 @@ class KafkaTopology(
                    emptyList<IndexReport>()
                }
            }
-            .map { key, value -> KeyValue("$key-${value?.report?.step}", klaxon.toJsonString(value)) }
+            .map { key, value -> KeyValue("$key-${value.report.step}-${value.metadata.sessionId}", klaxon.toJsonString(value)) }
            .to(settings.outputTopic)

        return builder