c++ - c++ 客户端的 Kafka 凭据和使用者参数

Question

我正在尝试使用 c++ 使用 kafka msg。我已经安装了 librdkafka 并尝试了示例https://github.com/edenhill/librdkafka/blob/master/examples/rdkafka_example.cpp

现在我关心的是如何将用户名、密码和信任库传递给 kafka 消费者？

标签： c++apache-kafkalibrdkafka

Answer 1

根据代理配置的身份验证机制，您需要使用以下配置属性配置客户端：

• security.protocol=SASL_PLAINTEXT或SASL_SSL，取决于是否使用 SSL。
• sasl.mechanism=PLAIN或任何其他机制，请参阅CONFIGURATION.md
• sasl.username=...对于 PLAIN和sasl.password=..SCRAM-.. 机制。
• sasl.kerberos.service.name=..用于 GSSAPI/Kerberos。

有关所有可用的配置属性、SASL 机制等，请参见CONFIGURATION.md 。