Open
Description
Spring Boot hardcodes Kafka Admin Client security protocol to PLAINTEXT if custom KafkaConnectionDetails
is used. For producer and consumer it is easy to work around using DefaultKafkaConsumerFactoryCustomizer
and DefaultKafkaProducerFactoryCustomizer
but AdminClient
doesn't have similar customizer. Which means we cannot configure it security protocol in code.
Relevant piece of code:
The only workaround I see is replacing AdminClient
bean with custom one (which is not really desirable) or am I missing something?
Spring Boot version: 3.1.4