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

Question

我使用的是Spring Kafka 1.1.2-Spring Boot 1.5.0 RC版本，并且配置了一个自定义值serialiser/Deserialiser类，扩展org.springframework.Kafka.support.serializer.jsonSerializer/org.springframework.Kafka.support.serializer。这些类确实使用Jackson ObjectMapper，它可以通过构造函数提供。

是否可以从Spring上下文中注入ObjectMapper？我已经配置了一个ObjectMapper，我希望在序列化/反序列化程序中重用它。

Answer 1

您可以将JSONSerializer和JSONDeserializer配置为@bean。向它们注入所需的ObjectMapper。并在DefaultKafkaProducerFactory和DefaultKafkaConsumerFactorybean定义中使用这些bean：

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