In the previous tutorial, we explored two types of exception handlers in Spring for Apache Kafka Streams: DeserializationExceptionHandler and ProcessingExceptionHandler. In this tutorial, let’s learn about the remaining exception handler, ProductionExceptionHandler! As I mentioned in the previous tutorial, ProductionExceptionHandler handles errors that occur when the… Read More

To handle potential exceptions in applications using Spring for Apache Kafka Streams, you can configure the following settings: Configuration Handles Typical examples DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG Consumer deserialization failures Invalid JSON, corrupted Avro/Protobuf, wrong Serde PROCESSING_EXCEPTION_HANDLER_CLASS_CONFIG Exceptions thrown while processing records NullPointerException, ArithmeticException, business logic exceptions in map(),… Read More