Kafka连接从带有变量的文件中获取机密



我计划通过变量使用Kafka外部秘密。基本上,我想从文件中传递密码字段。但该文件不包含密码,相反它会调用一个命令并获取密码。这是我的示例文件。

pass=$(aws secretsmanager get-secret-value 
--secret-id dev/debezium/mysql/testservice/password 
--region ap-south-1)

在我的连接器配置中有这样一行。

"database.password": "${file:/etc/kafka/mysql-secret.properties:pass}",

但它似乎对我不起作用。知道吗?

"database.password": "${file:/etc/kafka/mysql-secret.properties:pass}",

这将简单地从指定的文件中读取值。它不会执行它。

Kafka Connect确实支持外部密码提供程序。我发现这看起来像是用AWS secretsmanager实现它的一个选项。

最新更新