在清除堆积消息、离线数据处理等场景下,需要消费过去某个时段的消息,或清除所有堆积消息,可以对 offset 进行重置操作。消息队列 Kafka版控制台支持重置消费位点,改变订阅者当前的消费位置,您可以通过重置消费位点功能直接从某个指定时间点、最新 offset 位点或指定 offset 位点来消费消息。
消息队列 Kafka版支持重置 Group、Topic 或分区级别的消费位点,支持的重置方式包括以下三种。
ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG
配置的时间,默认 10000ms。重置当前消费组订阅的所有 Topic 的消费位点。
重置方式 | 说明 |
---|---|
根据最新offset位点 | 跳过所有堆积消息,从最新位点开始消费。 |
根据时间点 | 从过去某个指定时间点开始消费,该时间点以 Topic 的消息存储时间为准。 |
重置当前消费组订阅的某个 Topic 的消费位点。
重置方式 | 说明 |
---|---|
根据最新offset位点 | 跳过所有堆积消息,从最新位点开始消费。 |
根据时间点 | 从过去某个指定时间点开始消费,该时间点以 Topic 的消息存储时间为准。 |
重置某个分区的消费位点。
重置方式 | 说明 |
---|---|
根据最新 offset 位点 | 跳过所有堆积消息,从最新位点开始消费。 |
根据时间点 | 从过去某个指定时间点的位点开始消费,该时间点以 Topic 的消息保留时间为准。 |
指定 offset 位点 | 从当前分区的某个指定位点开始消费。重置后,Group 在当前分区中将指定位点开始消费。 |