小编ach*_*hap的帖子

使用@KafkaListener时以编程方式设置属性

@KafkaListener在我的spring boot应用程序中使用了注释,而没有创建自定义KafkaListenerContainerFactorybean。我目前正在spring.kafka.consumer.value-deserializer我的application.yml文件中设置属性以分配我的反序列化器,并且更喜欢通过编程方式进行此操作以进行编译时检查。我意识到创建自己的KafkaListenerContainerFactory属性可以使我在工厂设置此属性,但是我想避免样板操作以及在进行SSL设置时出现一些额外的麻烦。

有没有一种简单的方法可以以编程方式设置我的值反序列化程序而无需创建自己的值KafkaListenerContainerFactory

java spring-boot spring-kafka

5
推荐指数
1
解决办法
475
查看次数

标签 统计

java ×1

spring-boot ×1

spring-kafka ×1