一尘不染

将ObjectMapper注入Spring Kafka序列化器/反序列化器

spring-boot

我正在将Spring Kafka 1.1.2-RELEASE与Spring Boot 1.5.0
RC一起使用,并且已经配置了扩展org.springframework.kafka.support.serializer.JsonSerializer/
的自定义值序列化器/反序列化器类org.springframework.kafka.support.serializer.JsonDeserializer。这些类确实使用了可通过构造函数提供的Jackson
ObjectMapper。

是否可以通过Spring上下文注入ObjectMapper?我已经配置了一个ObjectMapper,我想在序列化器/反序列化器中重复使用。


阅读 705

收藏
2020-05-30

共1个答案

一尘不染

您可以配置JsonSerializerJsonDeserializer作为@BeanObjectMapper向他们注入期望。并在DefaultKafkaProducerFactoryDefaultKafkaConsumerFactorybean定义中使用这些bean

    @Bean
    public ProducerFactory<Integer, String> producerFactory() {
        DefaultKafkaProducerFactory<Integer, String> producerFactory = 
                new DefaultKafkaProducerFactory<>(producerConfigs());
        producerFactory.setValueSerializer(jsonSerializer());
        return producerFactory;
    }
2020-05-30