1

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

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

4

1 回答 1

0

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

于 2019-07-31T11:49:10.667 回答