Ash*_*asu 0 security authentication oauth-2.0 apache-kafka
任何人都可以解释客户端或代理间通信如何使用 kafka 中的 OAUTHBEARER 身份验证机制进行？
您将需要实现两个使用名为AuthenticateCallbackHandler的接口的类。
第一个类实现登录流程，您需要在其中调用 OAuth 服务器来检索令牌。此类将由您的客户端使用或用于代理间连接。
第二个类实现验证流程，您将在其中调用您的 OAuth 服务器来检查发送令牌是否有效。此类将仅在 Kafka Broker 中使用。
我在github.com/jairsjunior/kafka-oauth有一个这个实现的例子
如果您想了解如何使用这种 SASL 机制设置 Kafka 代理，请参阅包含所有步骤的文章。 https://medium.com/@jairsjunior/how-to-setup-oauth2-mechanism-to-a-kafka-broker-e42e72839fe
| 归档时间： |
|
| 查看次数： |
2807 次 |
| 最近记录： |