I asked in the Kafka Slack server how to handle testing a polling mechanism I have for consuming messages, that runs indefinitely. The solution offered was a CountdownLatch, which would allow me to halt the polling while testing. I’m wondering if there is a more “Kotlin-esk” way to solve this rather than the countdown latch?

could you share an example of the code you have at the moment? there’s some docs on async programming techniques here: https://kotlinlang.org/docs/async-programming.html#coroutines Coroutines are good for suspending work, and they’re very Kotlin-esque, but they are a big step to take if you just want a small util in your test code!

https://github.com/bthode/kafkagram/blob/master/telegram-response/src/main/kotlin/com/tatq/consumer/TelegramIngest.kt This is how I’m trying to use coroutineScope current. I had a finally block that I believe was being invoked when it was suspended, which I was having close my Kafka consumer.