【问题标题】:Kafka credentials and consumer parameters for c++ clientc++ 客户端的 Kafka 凭据和使用者参数
【发布时间】:2020-02-13 11:42:14
【问题描述】:

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

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

【问题讨论】:

  • 您是否查看了主要自述文件以了解 ssl 或 sasl 配置的可用属性?信任库仅在 Java 中。您需要转换为证书

标签: c++ apache-kafka librdkafka


【解决方案1】:

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

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

请参阅CONFIGURATION.md 了解所有可用的配置属性、SASL 机制等。

【讨论】:

  • 您好伊登希尔,感谢您的回复。我正在尝试理解您在github.com/edenhill/librdkafka/blob/master/examples/… 提供的示例,我可以看到代理、groupid 值作为 cmd 参数。我有点困惑,如何传递 configuration.properties。到这个 C++ 程序。临时配置对象会自动获取属性吗?
  • conf->set("security.protocol", "SASL_PLAINTEXT", errstr);
猜你喜欢
  • 1970-01-01
  • 2019-12-04
  • 1970-01-01
  • 1970-01-01
  • 2018-09-15
  • 1970-01-01
  • 2015-09-18
  • 1970-01-01
  • 2020-11-26
相关资源
最近更新 更多