<Spring Kafka Streams : Custom Deserialization Err...

# stackoverflow

[user]

Spring Kafka Streams : Custom Deserialization Error Handler implementation with Functional Programming
I have set the ErrorHandlingDeserializer for both key & value, and a delegate as StringDeserializer & IntegerDeserializer for the key & value respectively.So far, this works well. When the IntegerDeserializer fails to deserialize a string input, how can I set the CommonErrorHandler? I am using @Bean + Consumer as the consumer.
The control always goes to the DefaultErrorHandler in KafkaMessageListenerContainer as below:
at...