反序列化后如何处理SerializationException

Question

我在Spring Kafka设置中使用Avro和模式注册表。

我想以某种方式处理serializationexception，它可能在反序列化过程中引发。

我找到了以下两个资源：

https://github.com/spring-projects/spring-kafka/issues/164

有人知道如何在Spring Boot中捕获serializationexception吗？

我使用的是Spring Boot 2.0.2

编辑：我找到了解决办法。

public class SerializationExceptionHandler extends ContainerStoppingErrorHandler {

    @Override
    public void handle(Exception thrownException, List<ConsumerRecord<?, ?>> records, Consumer<?, ?> consumer,
                       MessageListenerContainer container) {

        //Only call super if the exception is SerializationException
        if (thrownException instanceof SerializationException) {
            //This will shutdown the container.
            super.handle(thrownException, records, consumer, container);
        } else {
            //Wrap and re-throw the exception
            throw new KafkaException("Kafka Consumer Container Error", thrownException);
        }
    }
}

@Bean
public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<Integer, String>>
kafkaListenerContainerFactory(JpaTransactionManager jpa, KafkaTransactionManager<?, ?> kafka) {

    ConcurrentKafkaListenerContainerFactory<Integer, String> factory =
            new ConcurrentKafkaListenerContainerFactory<>();

    factory.setConsumerFactory(consumerFactory());
    factory.setConcurrency(1);
    factory.getContainerProperties().setPollTimeout(3000);

    factory.getContainerProperties().setErrorHandler(new SerializationExceptionHandler());

    factory.getContainerProperties().setTransactionManager(chainedTxM(jpa, kafka));
    return factory;
}

Answer 1

Spring无能为力；反序列化发生在使用者获得任何数据之前。你需要增强解串器。

然而，我希望能够抛出一个异常，而不是返回null。

这不会有任何帮助，因为Kafka不知道如何处理例外。再次；这一切都发生在数据可用之前，因此返回null（或其他一些特殊值）是最好的技术。