You can reset the consumer offset to skip the accumulated messages instead of consuming them, or to consume messages after a certain time point whether or not these messages have been consumed before.
Note: RocketMQ does not support resetting consumer offsets in broadcasting consumption mode or by message ID, message key, or tag currently.
In the left-side navigation pane of the RocketMQ console, choose Groups.
Locate the group ID and the corresponding topic of the consumer offset that needs to be reset, and click More in the Actions column and then click Reset Consumer Offset.
In the Reset Consumer Offset dialog box, select Skip All Accumulated Messages to Consume from the Latest One or Reset by Time Point. The two options are described as follows:
Skip All Accumulated Messages to Consume from the Latest One: If this option is selected, the group ID skips all accumulated (unconsumed) messages under the topic and starts to consume from the latest message sent.
Note: It takes no effect on messages for which the system returns “reconsumeLater”, that is, the messages that are subjected to a retry procedure.
Reset by Time Point: If this option is selected, a time selection widget appears. Select a specific time in the widget. Only the messages that are sent after the selected time are consumed.
The time range allowed for the time selection widget ranges from the production time of the earliest message stored in the topic to that of the latest message stored in the topic.
If the selected time falls out of the allowed time range, the system processes the time range with the following logic:
If the selected time is earlier than the earliest start time allowed, the consumer offset is reset to the earliest start time allowed.
If the selected time is later than the latest end time allowed, the consumer offset is reset to the latest end time allowed.
- Click OK to reset the consumer offset.