Kafka权威指南（第2版）

保护

Kafka

｜

223

.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));

return new ConfigData(data, configData.ttl());

}

@Override

public void close() {}

}

➊

通过环境变量

PASSPHRASE

来提供用于解密密码的密码短语。

➋

用

gpg

解密配置文件。返回值中包含了全部的解密配置参数。

➌

将配置数据解析成

Java

属性。

➍

如果遇到错误，就抛出

RuntimeException

异常。

➎

调用者可能想要获取指定文件中的部分属性，我们在这里加载所有属性，并返回调用者

请求的部分。

你可能还记得，

11.3.2

节中使用了标准的

Kafka

配置类来从外部文件加载凭证

。现在可以

用

gpg

来加密这个文件。

gpg --symmetric --output credentials.props.gpg \

--passphrase "$PASSPHRASE" credentials.props

现在在原始属性文件中添加间接配置和提供程序，这样

Kafka

客户端就可以从被加密的文

件中加载它们的证书了。

username=${gpg:/path/to/credentials.props.gpg:username}

password=${gpg:/path/to/credentials.props.gpg:password}

config.providers=gpg ...