使用JAAS VS librdkafka oAuthBearer使用SASL进行身份验证

nuypyhwy  于 2023-10-15  发布在  Apache
关注(0)|答案(1)|浏览(164)

我们有一个kafkaProducer cpp应用程序,它将向kafkaBrokers发送数据,kafkaBrokers配置为使用JAAS-OAUTHBEARER进行身份验证。

  • 我可以在cpp kafkaProducer中使用JAAS吗?
  • 如果没有JAAS(带有librdkafka的oauth机制),我可以向配置了JAAS的代理生成数据吗?
    Kafka制作人姓名:
SaslConfigs.SASL_JAAS_CONFIG = "org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required"
SECURITY_PROTOCOL_CONFIG =  "SASL_PLAINTEXT"
sasl.mechanism = "OAUTHBEARER"
sasl.login.callback.handler.class = OAuthClientCallbackHandler.class.getName()

Kafka客户端

rd_kafka_conf_set (conf, "bootstrap.servers", brokers)
rd_kafka_conf_set (conf, "security.protocol", "SASL_PLAINTEXT")
rd_kafka_conf_set (conf, "sasl.mechanism", "OAUTHBEARER")
rd_kafka_conf_set_oauthbearer_token_refresh_cb(conf, token_refresh_cb_fun)

这两个可以使用oauth机制连接和发送数据吗?

uqcuzwp8

uqcuzwp81#

JKS / JAAS是Java特有的。代理运行Java,所以是的,它是必需的。
对于非Java * 客户端 *,不能使用它,您需要X.509证书沿着其他SASL证书,例如

sasl.oauthbearer.config
sasl.oauthbearer.client.id
sasl.oauthbearer.client.secret
sasl.oauthbearer.token.endpoint.url
sasl.oauthbearer.method
sasl.oauthbearer.scope

相关问题