@Override
    public DeserializationHandlerResponse handle(final ProcessorContext context,
                                                 final ConsumerRecord<byte[], byte[]> record,
                                                 final Exception exception) {

        log.warn("Exception caught during Deserialization, " +
                 "taskId: {}, topic: {}, partition: {}, offset: {}",
                 context.taskId(), record.topic(), record.partition(), record.offset(),
                 exception);

        return DeserializationHandlerResponse.CONTINUE;
    }
Deserialization handler that logs a deserialization exception and then
signals the processing pipeline to continue processing more records.
streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java