基于librdkafka的C++ KafkaProducer与JAAS-OAUTHBEARER认证适配问询

问题1：该C++生产者能否使用JAAS进行认证？ #

不能。JAAS是Java平台专属的认证配置机制，librdkafka作为C/C++语言实现的Kafka客户端库，不支持JAAS的配置格式，它拥有一套独立的认证参数配置体系。

问题2：不使用JAAS，仅通过librdkafka的OAuth机制能否向JAAS配置的Broker生产数据？ #

可以。Kafka Broker的JAAS配置只是服务端的认证规则定义，只要客户端遵循OAUTHBEARER规范完成认证流程（比如正确获取并传递有效OAuth令牌），无论使用Java还是C++客户端，都能与Broker建立连接并发送数据。librdkafka的OAUTHBEARER实现完全兼容Kafka的OAuth认证协议，和服务端是否采用JAAS配置无关。

问题3：以下给出的Kafka生产者配置与C++客户端配置是否可通过OAuth机制连接并发送数据？ #

Kafka生产者（Java）配置： #

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客户端（C++）配置： #

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)

可以，两者的配置逻辑完全匹配：

• Java端的Kafka生产者配置指定了SASL_PLAINTEXT安全协议、OAUTHBEARER认证机制，通过OAuthClientCallbackHandler处理令牌的获取逻辑；
• C++客户端通过librdkafka配置了相同的security.protocol和sasl.mechanism，同时设置token_refresh_cb_fun令牌刷新回调函数来负责OAuth令牌的获取与刷新，这和Java端的回调处理器作用一致。

只要C++端的令牌刷新回调能正确获取到符合Broker验证要求的有效OAuth令牌，就能正常连接Broker并发送数据。

内容的提问来源于stack exchange，提问作者indev