clean DefaultLitePullConsumerImpl after start fail

yuz10 · Sep 21, 2024 · 01cb8c7 · 01cb8c7
1 parent 576f0b7
commit 01cb8c7
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...t/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java b/...t/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
@@ -307,7 +307,12 @@ public synchronized void start() throws MQClientException {
 
                 log.info("the consumer [{}] start OK", this.defaultLitePullConsumer.getConsumerGroup());
 
-                operateAfterRunning();
+                try {
+                    operateAfterRunning();
+                } catch (Exception e) {
+                    shutdown();
+                    throw e;
+                }
 
                 break;
             case RUNNING: