将 IBM EventStreams 与 C/C++ 结合使用答案

【问题标题】：Using IBM EventStreams with C/C++将 IBM EventStreams 与 C/C++ 结合使用
【发布时间】：2019-07-31 01:50:31
【问题描述】：

我需要使用来自 C++ 程序的事件流。正在寻找示例代码。

尝试了来自 librdkafka 的 ./rdkafka_example，我没有收到任何错误消息，但消息无法通过。这可能是授权问题，因为我找不到向代码提供凭据的位置。任何地方都有示例 c++ 程序吗？

【问题讨论】：

标签： ibm-eventstreams

【解决方案1】：

Librdkafka 附带了一些可用于 Event Streams 的 C++ 示例。

例如，对于 Cloud Event Streams，使用 rdkafka_example_cpp 示例：

要生产，运行：

./rdkafka_example -P -t <TOPIC> -b <BOOTSTRAP_SERVERS> \
  -X security.protocol=SASL_SSL -X sasl.mechanisms=PLAIN -X sasl.username=<USERNAME> \
  -X sasl.password=<PASSWORD> -X ssl.ca.location=<CA_PATH> -X api.version.request=true \
  -X broker.version.fallback=0.10.2.1 -X log.connection.close=false

要消耗，运行：

./rdkafka_example -C -t <TOPIC> -p 0 -b <BOOTSTRAP_SERVERS> \
  -X security.protocol=SASL_SSL -X sasl.mechanisms=PLAIN -X sasl.username=<USERNAME> \
  -X sasl.password=<PASSWORD> -X ssl.ca.location=<CA_PATH> -X api.version.request=true \
  -X broker.version.fallback=0.10.2.1 -X log.connection.close=false

用您的 Event Streams 凭据替换 <> 之间的占位符。

查看示例中如何使用-X 传递的参数来构建配置：https://github.com/edenhill/librdkafka/blob/master/examples/rdkafka_example.cpp#L342-L375

【讨论】：

花了太长时间才尝试，但这就像 Mickael 描述的那样有效。谢谢！