From 275fb27a292947ef078db5e58b30bf52188f05e2 Mon Sep 17 00:00:00 2001 From: Adam <897017+aSemy@users.noreply.github.com> Date: Sun, 26 Jun 2022 14:59:09 +0200 Subject: [PATCH] Kafka Stream instance -> stop coroutine only when NOT_RUNNING --- .../dev/adamko/kafkatorio/processor/KafkatorioTopology.kt | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git 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 index 8da6383..1aa3e53 100644 --- 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 } }