zookeeper librdkafka示例

Question

大家好，我是卡夫卡的新手，必须在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中获取这些消息。

然而，当我从本地主机连接并运行下面的命令时，我看不到任何关于std out的消息。

./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