
您可以配置
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; }欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)