default.production.exception.handler is not called on serialization error

[Katya Gorshkova]

Hi!

I use Kafka Streams 1.1.0 and have a problem with processing serialization errors.

I have two topics, incoming and outcoming, each has different avro schema. I read data from the incoming topic, filter them, map them with mapValues method and write them to output topic. 

If during the mapping some mandatory fields are null then NullPointerException is thrown and the stream shuts down.

I have the following properties:

default.production.exception.handler=mypackage.ProductionHandler

default.deserialization.exception.handler=org.apache.kafka.streams.errors.LogAndContinueExceptionHandler

However neither of the handlers is called. Is it a correct behavior?

Thanks,

Katya