我正在使用来自https://github.com/edenhill/librdkafka/blob/master/examples/consumer.c的 consumer.c没有任何更改并执行它./consumer broker groupid topicname并rd_kafka_consumer_poll在大多数情况下返回 null （某些 groupid 值除外) 即使 kafka 集群中存在数据。我会理解是否有一些调用返回 null，但我不明白为什么它总是为 null。
我尝试将轮询超时从100msto增加1000ms，它仍然没有任何区别，并且一直返回 null 。但在某些随机groupid值下，它确实会从集群中获取所有数据。在重复运行时，我必须不断将groupid值增加到随机值，以便消费者获取数据。
- 这是预期的行为
rd_kafka_consumer_poll吗？或者我在实施中有什么需要改变的。