kafka消费reset offset问题
kafka消费端包如下错误:
2016-07-12 14:02:45,076 [ConsumerFetcherThread-order-consumer-group_iZ25mmzglleZ-1468299172455-8b8f5ebd-0-3] ERROR [ConsumerFetcherThread:97] - [ConsumerFetcherThread-order-consumer-group_iZ25mmzglleZ-1468299172455-8b8f5ebd-0-3], Current offset 458416 for partition [order-consumer-group,0] out of range; reset offset to 580644
如何让消费者从 offset 458416 消费。配置auto.offset.reset=smallest 无效。有什么比较好的办法处理?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(3)
请问解决了吗?做测试时也发现这样的问题。推数据时,关掉一台的服务。客户读数据就有这样的问题。
问题是这个问题,怎么处理呢
提示很明显
458416已经超出了broker的offset范围了,也就是说broker的最小的offset也大于458416了