I’m using the latest release of akka-kafka - 1.0.4.
I have read the following thread but it doesn’t seem to cover the situation of using schema registry to handle errors. I have been exploring this pr but it seems that there is no way for the exception to bubble up to the decider added to a given stage. I have explored the tests but they don’t cover situations handling the error. I would like to skip over non deserializable records.
I am currently blocked without being able to progress consuming the stream. Any ideas are welcome.