I have multiple globalktable join with corresponding transformer using DSL in our Kafka stream.
If there is any exception in the transformer, i want to commit the Kafka offset and sent to a dead letter queue.
Instead of writing try catch in my transformer code , is there any other way of solving it?
Hi @Itsbikram ,
What you have described, using a try...catch block in the transformer, is the best way to achieve what you want in the case of an error.
The only internal error handling Kafka Streams offers is the DeserializationExceptionHandler for dealing with deserialization errors when consuming from a topic.