Throwing Exceptions inside a coroutine causes reactor to go on an infinite loop
I have the following code which attempts to process a kafka message, and if it fails, logs/publish it to another topic for later processing.
I have the following code which attempts to process a kafka message, and if it fails, logs/publish it to another topic for later processing.