Fix fatal error being forwarded.

e670c321 · Jonas Waeber · 4027b61a · e670c321
Commit e670c321 authored Mar 19, 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
@@ -158,7 +158,7 @@ class KafkaTopology(private val settings: SettingsLoader) {

    private fun streamOutput(stream: KStream<String, Pair<String?, Report>>) {
        stream
-            .filter { _, value -> value != null }
+            .filter { _, value -> value.second.status != ReportStatus.fatal }
            .mapValues { value -> value.first }
            .to(settings.outputTopic)