-
Notifications
You must be signed in to change notification settings - Fork 497
Closed
Description
Summary
ClientUtils.clusterClientBaseConfig currently builds the base configuration for internal producers/consumers using only the inter-broker endpoint and the protocol/mechanism. It omits SSL and listener-prefixed security properties, so internal clients fail to connect when the inter-broker listener requires TLS or SASL.
Steps to reproduce
- Configure a broker with inter.broker.listener.name pointing to a listener that uses SSL or SASL_SSL.
- Supply the necessary ssl.* properties (e.g., ssl.truststore.location, ssl.keystore.location) under the listener prefix.
- Start any internal component (e.g., table Channel) that relies on ClientUtils.clusterClientBaseConfig.
Expected result
Internal clients inherit the listener's SSL/SASL settings and connect successfully.
Actual result
The returned lack those SSL/SASL entries, so the handshake fails.
Proposed fix
Merge the global / and listener-prefixed configs into the base client Properties before returning.
Metadata
Metadata
Assignees
Labels
No labels