Processor Error Handling

Processor errors are exceptions thrown from the code running in a stream processor, which include operations such as filter, map, and flatMap. That means that the source of these errors is the code containing our application’s logic.

Default behavior

When Kafka Streams encounters a processor exception, its default behavior is to shut down the application. Let’s simulate this—below, we have a stateless topology. It has a mapValues operator which throws an exception randomly: