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

Question

我希望 kafka 消费者使用来自主题的特定/指定分区的消息

它使用 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