Spring Kafka中如何在application.properties配置AuthExceptionRetryInterval属性?
正确配置Spring Kafka的AuthExceptionRetryInterval属性
你之前的配置错误在于混淆了Spring Kafka监听器属性和Apache Kafka原生消费者属性的配置层级:
spring.kafka.consumer.properties.*用于传递Apache Kafka原生消费者的配置参数,而AuthExceptionRetryInterval是Spring Kafka自身ConsumerProperties类的属性,不属于原生消费者配置范畴。- 你尝试的
spring.kafka.listener.consumer.*路径也不正确,该属性直接属于监听器容器配置,无需嵌套consumer层级。
正确的配置方式是使用Spring Boot松散绑定的短横线命名格式,对应ConsumerProperties中的authExceptionRetryInterval属性:
spring.kafka.listener.auth-exception-retry-interval=60ms
说明:
- Spring Boot的松散绑定机制会自动将短横线分隔的配置名映射为驼峰命名的Java属性,因此
auth-exception-retry-interval会对应到authExceptionRetryInterval。 - 该配置直接归属
spring.kafka.listener前缀,因为ConsumerProperties是Spring Kafka监听器容器的专属配置类,与原生消费者配置分属不同层级。
内容的提问来源于stack exchange,提问作者Remo
相关产品推荐
相关产品推荐

