我们有一个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机制连接和发送数据吗?
1条答案
按热度按时间uqcuzwp81#
JKS / JAAS是Java特有的。代理运行Java,所以是的,它是必需的。
对于非Java * 客户端 *,不能使用它,您需要X.509证书沿着其他SASL证书,例如