我有一个Sping Boot 应用程序,它集成了Spring Kafka项目。
我想在我的application.properties
中设置AuthExceptionRetryInterval
属性。
在https://docs.spring.io/spring-kafka/api/org/springframework/kafka/listener/ConsumerProperties.html中提到
虽然,我不能找出正确的方式来设置它。我不确定,如果以及如何Spring的“宽松绑定”干扰。IntelliJ的自动完成也没有建议它。我也不确定,如何在Spring环境中正确设置Apache configs。
它必须通过一个属性来完成,通过代码设置它不是我正在寻找的解决方案。
我试过了...
spring.kafka.consumer.properties.auth.exception.retry.interval=60ms
spring.kafka.listener.consumer.properties.auth.exception.retry.interval=60ms
spring.kafka.listener.consumer.auth.exception.retry.interval=60ms
谁能告诉我我需要做错什么?非常感谢!
1条答案
按热度按时间g6ll5ycj1#
仅仅因为getter/setter存在并不意味着它是原生的Kafka属性。
具体来说,该属性不是Kafka客户端配置,因此不能通过配置传递给消费者。
您可以定义自己的autowired属性,然后使用该值在代码中调用setter。