rocketmq中删除topic的时候如何清除掉所有对应的consumer的offset信息

Question

请教一个问题，我创建了一个topic，然后推了一些数据，并消费掉，同时更新offset到服务端，然后删除掉这个topic，重新创建一个同名的topic，发现原来的offset并没有被清掉，请问下删除topic的时候如何同时清掉topic对应的consumer的offset

通过resetOffsetByTime必须指定consumergroup，我这边删除topic的时候并不清楚有多少个group 。

感觉offset这个设计很不合理

Answer 1

在RocketMQ中，删除一个Topic并不会自动清除该Topic对应的Consumer的Offset。如果需要清除Consumer的Offset，可以通过以下两种方式实现：

1. 手动清除Consumer的Offset

可以通过调用Consumer的resetOffset方法来手动清除Consumer的Offset。具体步骤如下：

• 停止Consumer消费
• 调用resetOffset方法，将Offset重置为最新的Offset
• 重新启动Consumer消费

示例代码：

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group");
consumer.subscribe("topic", "*");
consumer.start();

// 停止Consumer消费
consumer.shutdown();

// 清除Consumer的Offset
consumer.resetOffsetByTimestamp(System.currentTimeMillis(), true);

// 重新启动Consumer消费
consumer.start();

1. 使用deleteTopic命令删除Topic

可以使用RocketMQ提供的deleteTopic命令来删除Topic，并且该命令会自动清除该Topic对应的Consumer的Offset。具体步骤如下：

• 停止Consumer消费
• 使用deleteTopic命令删除Topic
• 重新启动Consumer消费

示例代码：

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group");
consumer.subscribe("topic", "*");
consumer.start();

// 停止Consumer消费
consumer.shutdown();

// 删除Topic
MQAdmin admin = new DefaultMQAdminExt();
admin.start();
admin.deleteTopic("topic");
admin.shutdown();

// 重新启动Consumer消费
consumer.start();

需要注意的是，使用deleteTopic命令删除Topic会导致该Topic下的所有消息都被删除，因此需要谨慎操作。