Bertalan Kondrat created KAFKA-17192:
----------------------------------------
Summary: MirrorMaker2 worker config does not pass config.providers
value to connectors
Key: KAFKA-17192
URL: https://issues.apache.org/jira/browse/KAFKA-17192
Project: Kafka
Issue Type: Bug
Components: mirrormaker
Affects Versions: 3.7.1, 3.7.0
Reporter: Bertalan Kondrat
Assignee: Bertalan Kondrat
MirrorMaker2 worker config does not pass config.providers value to connectors.
With this
[commit|https://github.com/apache/kafka/commit/8cfafba2794562840b0f1c537e304f084b9359cf#diff-015b9a2584a6c84806c633ec7fb59d7a9639bb7d8b206e582029af486881e41dL309]
we changed the behavior of the _stringsWithPrefix_ method.
The new implementation does not include the configurations where the prefix
exactly the same as the config key.
For example:
Prefix:
{code:java}
config.providers{code}
Configs:
{code:java}
config.providers=env
config.providers.env.class=org.apache.kafka.common.config.provider.EnvVarConfigProvider{code}
Result:
{code:java}
config.providers.env.class=org.apache.kafka.common.config.provider.EnvVarConfigProvider
{code}
The result does not include the
{noformat}
config.providers=env{noformat}
As a result of this behavior, the connectors could not resolve variables.
Reproduction is easy, just start an MM2 instance with the following config
{code:java}
ssl.truststore.location=${env:TRUSTSTORE_LOCATION}
config.providers=env
config.providers.env.class=org.apache.kafka.common.config.provider.EnvVarConfigProvider
{code}
Check the connector configs in the log. (grep for ${env:TRUSTSTORE_LOCATION})
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
