消息服务DMS使用实践 - 如何重置消费组位点

通过消费组A开始消费队列中的消息,消费到中途时由于故障导致已消费的消息在客户端未保存,所以需要重新再消费一遍,但是由于Kafka内部机制的原因已消费成功的消息无法再次消费,可怎办呢? 终于在帮助中找到如下内容,可以解决我的问题: 如果想跳过某些未消费的消息,或者想重新消费队列中的已消费的消息,或者只想消费某个时间点之后的消息(这些消息不论之前是否消费过),那么可以通过“消费重置”功能实现选择性跳过
相关文章
相关标签/搜索