我用的是landoopKafka码头形象。我使用它的ui来创建jdbc源和jdbc接收器连接器，或者我也可以使用kafkarestapi来创建连接器。我有许多jdbc源连接器使用相同的连接url，用户名，密码。无论何时更改源数据库凭据，当前我都必须逐个更改所有连接器。有没有一种方法可以只外部化这些属性，让每个连接器都有其特定的属性，比如topic、query等。
rggaifut1#
在Kafka2.0中，你至少可以把秘密具体化。参考kip-297。我还没有亲自尝试过，而且可能只对你有用 ConfigDef.Type.PASSWORD 配置，而不仅仅是一般配置。。。从kip中提取变量替换的模式是 ${provider:[path:]key} ，在替换过程中只遵循一个间接级别。变量中的路径是可选的。这意味着如果您具备以下条件：
ConfigDef.Type.PASSWORD
${provider:[path:]key}
foo=${file:bar} bar=${file:baz}
你的文件包含
bar=hello baz=world
那么结果就是
foo=hello bar=world
因此，在docker中，可以卷装一个配置文件，然后在连接器配置负载中引用它
1条答案
按热度按时间rggaifut1#
在Kafka2.0中，你至少可以把秘密具体化。参考kip-297。
我还没有亲自尝试过，而且可能只对你有用
ConfigDef.Type.PASSWORD配置，而不仅仅是一般配置。。。从kip中提取
变量替换的模式是
${provider:[path:]key}，在替换过程中只遵循一个间接级别。变量中的路径是可选的。
这意味着如果您具备以下条件：
你的文件包含
那么结果就是
因此，在docker中，可以卷装一个配置文件，然后在连接器配置负载中引用它