加密Kafka连接属性文件中的sql密码

Question

如何加密 Kafka 连接属性文件中的密码

我的属性文件如下所示

connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
connection.url = jdbc:sqlserver://<connection string>
connection.user = <SQL user id>
connection.password = <Plain text password>
mode=incrementing 
name=<Topic name>
schema.partern=dbo
query = <select from view query>
table.types = VIEW
incrementing.column.name=Application_Identity

如何避免使用纯文本密码以避免安全违规？

我在 Linux 服务器中使用 Kafka，数据库作为 SqL 服务器。

Answer 1

1. 不建议独立连接。使用分布式模式，使用 JSON 配置
2. 取决于您的需求，但总的来说，Debezium 更适合从数据库捕获 CDC
3. Kafka Connect 支持工作器属性的配置外部化，而不是加密。根据您使用的 Connect 版本，环境变量是最简单的。