Kafka消费者赢了,开始消耗,当前偏移值是空的
我们在卡夫卡(Kafka)有一个工作的主题消费者设置。在尝试在另一个环境中创建相同的过程时,消费者不会开始从主题中阅读。我尝试重新启动,删除,重命名和许多事情,但它们都没有起作用。
当我用命令kafka-consumer-groups-deScribe
描述消费者组时,我得到了以下结果:
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG
G__BRC_SENDSMS BRC_SENDSMS 0 - 31 -
请注意,当前偏移量不是零。由于它不是零,因此也没有滞后。这是正常的吗?我应该怎么办?
We have a working topic-consumer setup in kafka. While trying to create the same in another environment, the consumer does not start reading from the topic. I've tried restarting, deleting, renaming and many things but none of them worked.
When I describe the consumer group with the command kafka-consumer-groups --describe
I got this result:
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG
G__BRC_SENDSMS BRC_SENDSMS 0 - 31 -
Mind how current offset is not zero. Since it is not zero, there is also no lag too. Is this normal? What should I do?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
可以从
brc_sendsms
,分区 0 读取。同时。更改组ID,应该开始读取数据。或在主题中添加更多分区,您应该在所有消费者实例之间看到小组重新平衡并分发消息。如果不起作用,请检查此“其他环境”中的网络配置,例如kafkaadvertied.listeners
。如果没有当前的偏移,那么您的消费者实际上是否承诺?
Only one consumer in
group.id=G__BRC_SENDSMS
can read fromBRC_SENDSMS
, partition0
at the same time. Change the group id, and it should start to read data. Or add more partitions to the topic, and you should see the group rebalance and distribute messages between all consumer instances. If neither work, then check networking configurations in this "other environment", such as the Kafkaadvertised.listeners
.If there is no current offset, then has your consumer actually committed yet?