Kafka ErrorHandlingDeserializer 사용하기

아래와 같은 오류가 발생했을 때는 ErrorHandlingDeserializer 를 이용해 오류를 확인할 수 있다.

This error handler cannot process 'SerializationException's directly; please consider configuring an 'ErrorHandlingDeserializer' in the value and/or key deserializer

ErrorHandlingDeserializer

    @Bean
    public ConsumerFactory<String, StockChangeDto> stockChangeConsumer() {

        Map<String, Object> props = new HashMap<>();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "StockChange");

        return new DefaultKafkaConsumerFactory<>(
                props,
                new StringDeserializer(),
                // new JsonDeserializer<>(StockChangeDto.class)
                new ErrorHandlingDeserializer(new JsonDeserializer<>(StockChangeDto.class))
        );