在Spring Kafka中设置AuthExceptionRetryInterval属性

chy5wohz  于 2023-04-19  发布在  Apache
关注(0)|答案(1)|浏览(247)

我有一个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

谁能告诉我我需要做错什么?非常感谢!

g6ll5ycj

g6ll5ycj1#

仅仅因为getter/setter存在并不意味着它是原生的Kafka属性。
具体来说,该属性不是Kafka客户端配置,因此不能通过配置传递给消费者。
您可以定义自己的autowired属性,然后使用该值在代码中调用setter。

相关问题