Spring Kafkaシリアライザ/デシリアライザにObjectMapperを注入してください

Question

私はSpring Boot 1.5.0 RCでSpring Kafka 1.1.2-RELEASEを使用しており、org.springframework.kafka.support.serializer.JsonSerializer/org.springframework.kafka.support.serializer.JsonDeserializerに拡張されたカスタム値serialiser/deserialiserクラスを設定しました。これらのクラスは、コンストラクタを介して提供できるJackson ObjectMapperを使用します。

SpringのコンテキストからObjectMapperを挿入することは何とかできますか？私はすでにシリアライザ/デシリアライザで再利用したいObjectMapperを設定しています。

Answer 1

JsonSerializerとJsonDeserializerを@Beanに設定できます。 希望するものをObjectMapperに注入します。私の重複を解決する

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