Keycloak如何与kafka集成？

Question

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

问题一：kafka broker到kafka broker如何用keycloak实现安全？

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

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

Answer 1

您可以将 Kafka 配置为使用在最新 kafka 版本中实现的 AUTHBEARER，您可以找到有关如何配置 here 的更多信息。

并且还可以从 Kafka doc

获取有关该功能的更多信息

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