Dan T
12/19/2017, 6:03 PMprivate fun processMessage(record: KafkaMessage) {
runBlocking {
launch {
handler.doSomething(record.data) // its implementation simply returns
log.debug("2") // NOT CALLED
}.join()
}
}
dave08
12/19/2017, 6:25 PMasync { }.await()
, itll throw if there is an exception...Dan T
12/19/2017, 6:33 PMelizarov
12/19/2017, 6:43 PMrunBlocking { handler.doSomething(...) }
Dan T
12/19/2017, 7:18 PM