(rocketmq) branch develop updated: [ISSUE #9703] Remove pull offset and reset offset when deleting topic (#9704)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new d0e31a2b34 [ISSUE #9703] Remove pull offset and reset offset when 
deleting topic (#9704)
d0e31a2b34 is described below

commit d0e31a2b341a04abcf4c08eab495f8e77f04bb08
Author: qianye <wuxingcan....@alibaba-inc.com>
AuthorDate: Tue Sep 16 10:49:34 2025 +0800

    [ISSUE #9703] Remove pull offset and reset offset when deleting topic 
(#9704)
---
 .../java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
index a6cd9ad987..e1e1cb4b02 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
@@ -97,6 +97,8 @@ public class ConsumerOffsetManager extends ConfigManager {
                 if (arrays.length == 2 && topic.equals(arrays[0])) {
                     it.remove();
                     removeConsumerOffset(topicAtGroup);
+                    pullOffsetTable.remove(topicAtGroup);
+                    resetOffsetTable.remove(topicAtGroup);
                     LOG.warn("Clean topic's offset, {}, {}", topicAtGroup, 
next.getValue());
                 }
             }