我计划通过变量使用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实现它的一个选项。