Kafka Stream instance -> stop coroutine only when NOT_RUNNING

2022-06-26 14:59:09 +02:00 · 2022-06-26 14:59:09 +02:00 · 275fb27a29
commit 275fb27a29
parent f4744c7286
1 changed files with 5 additions and 2 deletions
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/KafkatorioTopology.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/KafkatorioTopology.kt
@ -105,8 +105,11 @@ internal class KafkatorioTopology(
        streams.setStateListener { newState: KafkaStreams.State, _ ->
          when (newState) {
            KafkaStreams.State.NOT_RUNNING,
-            KafkaStreams.State.ERROR -> cont.resume(newState)
-            else                     -> Unit // do nothing
+//            KafkaStreams.State.ERROR,
+                 -> if (cont.isActive) {
+              cont.resume(newState)
+            }
+            else -> Unit // do nothing
          }
        }