Description
In our setup (using Spring cloud stream Kafka binder), we see log messages like:
The configuration 'ssl.keystore.password' was supplied but isn't a known config
logged by org.apache.kafka.clients.admin.AdminClientConfig. The Kafka binder actually uses SSL and security.protocol is set to SSL.
Looking through the code, a few things seem odd:
- The log message says "isn't a known config" but that's not true. It is known, i.e. defined in ConfigDef, but not used.
- The method for detecting whether a config is actually used is not complete. ChannelBuilders.channelBuilderConfigs() for example extracts the configs to use for the created channel builder using new HashMap(config.values()) thus get() won't mark a config as used anymore.
Attachments
Issue Links
- links to