Keycloak如何与kafka集成？

Question

我已经配置了3个节点的kafka集群。现在我们要使用 Keycloak 为 kafka 设置安全性。请让我知道有什么方法可以做到这一点。

问题1：如何使用keycloak实现kafkabroker对kafkabroker的安全性？

问题2：如何使用keycloak实现kafka客户端到kafkabroker的安全性？

注意：我们已经设置了 Keycloak。

Answer 1

您可以配置 Kafka 以使用AUTHBEARER最新版本中实现的功能，您可以在此处kafka找到如何配置的更多信息。

还可以从Kafka 文档获取有关该功能的更多信息

您需要实现 org.apache.kafka.common.security.auth.AuthenticateCallbackHandler从 keycloak 获取令牌并验证来自 Keycloak 的令牌。