c - Zookeeper librdkafka 示例

Question

大家好，我是 kafka 新手，必须使用 C 语言开发一个项目。

我已经从kafka_2.10-0.8.2.0.tgz安装了代理和zookeeper

bin/kafka-server-start.sh config/server.properties

bin/zookeeper-server-start.sh config/zookeeper.properties

我编写了一个 C 程序作为生产者，我的消费者的工作就是来自这个命令。

 bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic vCPE_Events --from-beginning

到这里为止一切都很好。

现在我尝试从 librdkafka 库提供的 rdkafka_zookeeper_example 获取这些消息。

但是，当我从本地主机连接并运行以下命令时，我在标准输出上看不到任何消息。

./rdkafka_zookeeper_example -C -t v_Events -p 1 -k localhost:2181 -A -X debug=all  -Xfetch.message.max.bytes=200 -X log_level=6 -d all

我也尝试从同一示例生成消息

./rdkafka_zookeeper_example -P -t v_Events -p 1 -k localhost:2181

另请注意，consumer.sh 脚本也不会选择我从 Zookeeper_example 发送的消息。

你能告诉我我做错了什么吗？

Answer 1

您已经创建了一个具有默认分区的主题，即 1因此，生产者和消费者上的 -p 选项的值都应该是 0

例如如果您创建了一个具有 10 个分区的主题，则 -p 可以具有从 0 到 9 的值