首页 > 解决方案 > 如何将 Kafka 与 OpenID-Connect 结合使用?

问题描述

我从卡夫卡开始。

我看到我能够在生成消息时传递标头。

传统上,人们会有一个 Web 客户端(单页应用程序),用户可以在其中通过一些远程 oidc idp 登录并接收令牌。然后,该令牌通过Authentication: Bearer token-here标头发送到某个 RESTful 后端,在该后端检查令牌的有效性并处理有效负载,保存到数据库或其他,并返回或不返回某些内容。

现在有 Apache Kafka。它有一个 REST 代理。我可以将标头传递给 REST 代理并生成消息或使用它们,但我对“保护我的 RESTful JSON API”部分感兴趣。

目前,在没有 Kafka 的情况下,我有一个 oidc 代理(使用 keycloak,即 keycloak-gatekeeper)来过滤哪个请求进入后端,或者我有一个 oidc 客户端,它作为后端内部的一些中间件功能进行令牌验证. 我认为,无论如何,无效请求都不会像在 Kafka 中那样被“记录”。

oidc 令牌验证和请求过滤在 Kafka/Confluent 生态系统中的什么位置?

假设我们有一个与 Confluent REST 代理通信的 SPA。一些登录用户想要发布消息,而一些未登录用户不应该能够。

Kafka 和/或其工具如何处理这种情况?

标签: apache-kafkaopenid-connectkafka-rest

解决方案


Kafka 通常使用 SASL 和其他 Authorization 插件来阻止访问。

证书将在客户端(此处为 REST 代理)之间分发。与任何其他 Web 服务器一样,您将需要其他代理或插件防止进一步访问或审核请求。

HTTPS 证书将用于保护到 REST 代理的流量,但您似乎在询问更具体的内容。

文档中没有提到 OpenID,只有 LDAP RBAC,作为商业产品


推荐阅读