Commit dbed0cf6 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Migrate kafka code

parent 15dc50b9
Pipeline #24727 passed with stages
in 5 minutes and 6 seconds
...@@ -104,7 +104,7 @@ class Service(settings: SettingsLoader) { ...@@ -104,7 +104,7 @@ class Service(settings: SettingsLoader) {
fun run() { fun run() {
stream.use { stream.use {
it.start() it.start()
while (stream.state().isRunning) { while (stream.state().isRunningOrRebalancing) {
log.info("Service is running.") log.info("Service is running.")
Thread.sleep(10_000L) Thread.sleep(10_000L)
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment