0

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

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

4

1 回答 1

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 。

于 2020-02-13T21:06:10.263 回答