Updated on 2024-09-20 GMT+08:00

Resetting the RocketMQ Consumption Offset

Resetting the consumption offset modifies the consumer position. Consumers consume messages from the modified positions.

Messages may be retrieved more than once after the offset is reset. Exercise caution when performing this operation.

Prerequisites

Procedure

  1. Log in to the console.
  2. Click in the upper left corner to select a region.

    Select the region where your RocketMQ instance is located.

  3. Click and choose Middleware > Distributed Message Service for RocketMQ to open the console of DMS for RocketMQ.
  4. Click a RocketMQ instance to go to the instance details page.
  5. In the navigation pane, choose Consumer Groups.
  6. In the row containing the desired consumer group, choose More > Reset Consumer Offset.
  7. Set parameters by referring to Table 1.

    Table 1 Parameters for resetting the consumer offset

    Parameter

    Description

    Topic Name

    Select the topic whose consumer offset is to be reset.

    Time

    Select a time point. After the reset is complete, retrieval starts from this time point.

    • Custom: Message consumption restarts from the customized time.
    • Earliest: Message consumption starts from the earliest time.
    • Latest: Message consumption starts from the latest time. The messages before this time will not be consumed.

  8. Click OK.
  9. Click Yes in the confirmation dialog box. The consumer offset is reset.