也许我错过了什么,如果是这样,请原谅我的无知。
这里我们有:
- 我们在 Kafka 集群中使用 TLS 身份验证侦听器(这可以更改,我们可以添加新类型的侦听器)。
- 从 Java 代码连接到 Kafka 主题时,我使用为 Kafka 用户生成的 SSL 证书。
如果我决定避免使用 SSL 证书,原因有两个:
- 我将仅从受信任的 OpenShift 集群 POD 连接到 Kafka 主题
- 为避免生产者/消费者端更新重新生成年度用户的 SSL 证书(因为 Kafka 生成的用户证书有效期为 1 年)
由于上述两个原因,KafkaUser 的 SCRAM-SHA-512 身份验证类型会是更好的(也是唯一的?)选择吗?或者 SCRAM-SHA-512 也需要 SSL 证书?
我看到的另一种方法是不进行身份验证,但我不确定 ACL 如何用于此类用户?我如何将用户正在连接的服务器信息传递给服务器。是否可以同时使用 ACL 而不是通过 SSL 证书或密码 Kafka 用户进行身份验证?
[UPD]环境建立在 Strimzi(OpenShift 中的 Apache Kafka 集群)之上