我希望 kafka 消费者使用来自主题的特定/指定分区的消息
它使用带有开关的kafka-console-consumer.sh --partition partition_number
我正在使用来自librdkafka的kafka_complex_consumer_example.c代码
在静态代码分析中，我觉得它可以达到我的目的，但我无法找出要传递给 main(int argc & char **argv) 函数的确切命令行参数，以便代码运行并开始使用主题的特定分区。
看看这里的代码 - rdkafka_complex_consumer_example.c
librdkafka 的完整 github 代码在这里 FYR
如果此代码不能达到目的，请指定一些其他可以提供帮助的代码