Closed
Description
Hi there I have a spring boot app that makes use of both a kafka consumer and producer. I have been able to configure mostly everything with YAML properties but one property I am coming up short is:
org.springframework.kafka.listener.ConsumerProperties.authExceptionRetryInterval (java.time.Duration)
It seems like this property should be included in the org.springframework.boot.autoconfigure.kafka.Listener static configuration class, but I don't see it. Based on the configuration of Spring Kafka, I think this should be the logical place to put it, for instance like so:
spring:
kafka:
listener:
auth-exception-retry-interval: 30s
ack-mode: record
concurrency: 2
client-id: sample
retry:
topic:
attempts: 5
backoff:
delay: 5000
bootstrap-servers:
- xxxxxxxxxxxxxxxxxxxxx
producer:
transaction-id-prefix: ${spring.application.name}
key-serializer: org.springframework.kafka.support.serializer.JsonSerializer
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
compression-type: zstd
retries: 5
properties:
"[linger.ms]": 1
consumer:
group-id: sample
key-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
value-deserializer: org.springframework.kafka.support.serializer.JsonSerializer
auto-offset-reset: latest
properties:
"[spring.json.trusted.packages]": com.sample
"[spring.json.use.type.headers]": false
properties:
"[security.protocol]": SASL_SSL
"[sasl.mechanism]": SCRAM-SHA-512
"[sasl.jaas.config]": ${kafka.sasl.jaas.config}
Unless I am missing something would it be possible to add this in as an enhancement, as this allows one to go full configuration based auto-configuration without the need of defining a custom property.
many thx!