-
Notifications
You must be signed in to change notification settings - Fork 41.3k
Open
Labels
status: pending-design-workNeeds design work before any code can be developedNeeds design work before any code can be developedtheme: containersTestcontainers, Docker Compose and Buildpack featuresTestcontainers, Docker Compose and Buildpack featurestype: enhancementA general enhancementA general enhancement
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:
Lines 208 to 209 in 4a6762a
if (!(connectionDetails instanceof PropertiesKafkaConnectionDetails)) { | |
properties.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "PLAINTEXT"); |
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
Metadata
Metadata
Assignees
Labels
status: pending-design-workNeeds design work before any code can be developedNeeds design work before any code can be developedtheme: containersTestcontainers, Docker Compose and Buildpack featuresTestcontainers, Docker Compose and Buildpack featurestype: enhancementA general enhancementA general enhancement