如何在kafka中消费来自主题的特定分区的消息

Question

我希望 kafka 消费者使用来自主题 particular/specified 分区 的消息

它使用 kafka-console-consumer.sh 和开关 --partition partition_number

我正在使用来自 librdkafka

的 kafka_complex_consumer_example.c 代码

根据静态代码分析，我觉得它可以达到我的目的，但我无法找到要传递给 main(int argc & char **argv) 函数的确切命令行参数，以便代码 运行 并开始使用主题的特定分区。

Have a look at the code here - rdkafka_complex_consumer_example.c

Full github code of librdkafka here FYR

如果此代码不能达到目的，请指定一些其他可以提供帮助的代码

Answer 1

如果您查看用法字符串，在主题名称后放置一个冒号指定从哪个分区使用

更具体地说，topicpartition 类型包含特定分区的信息，这一行创建了这些分区的列表

https://github.com/edenhill/librdkafka/blob/master/examples/rdkafka_complex_consumer_example.c#L528