您可以配置JsonSerializer
和JsonDeserializer
作为@Bean
。ObjectMapper
向他们注入期望。并在DefaultKafkaProducerFactory
和DefaultKafkaConsumerFactory
bean定义中使用这些bean :
@Bean
public ProducerFactory<Integer, String> producerFactory() {
DefaultKafkaProducerFactory<Integer, String> producerFactory =
new DefaultKafkaProducerFactory<>(producerConfigs());
producerFactory.setValueSerializer(jsonSerializer());
return producerFactory;
}