c - rd_kafka_consumer_poll() 大多数时候返回 null
问题描述
我正在使用来自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。
我尝试将轮询超时从100ms
to增加1000ms
,它仍然没有任何区别,并且一直返回 null 。但在某些随机groupid
值下,它确实会从集群中获取所有数据。在重复运行时,我必须不断将groupid
值增加到随机值,以便消费者获取数据。
- 这是预期的行为
rd_kafka_consumer_poll
吗?或者我在实施中有什么需要改变的。
解决方案
推荐阅读
- javascript - 从 Twitter API 获取更大分辨率的个人资料图片
- docker - 如何有效地使用 Docker 进行开发?
- javascript - 如何在简单的自动完成中缓存结果
- html - div 覆盖 flex 容器中的其他 div
- nginx - 使用 Gunicorn 在 Windows 机器上的烧瓶 Web 应用程序上配置 NGINX
- javascript - 尝试使用 JavaScript 和 CSS 创建数字 3.2.1 倒计时
- javascript - 反应无限幻灯片
- kotlin - 所有挂起函数都有一个作业吗?
- java - 我可以使用 com.android.internal.Itelephony 吗?
- android - 以可读形式转换数字值?