diff --git a/example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java b/example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java
index a0fdeeffbb..40f1db2e71 100644
--- a/example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java
+++ b/example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java
@@ -29,7 +29,7 @@ public class PushConsumerWithNamespace {
             msgs.stream().forEach((msg) -> {
                 System.out.printf("Msg topic is:%s, MsgId is:%s, reconsumeTimes is:%s%n", msg.getTopic() , msg.getMsgId(), msg.getReconsumeTimes());
             });
-            return ConsumeConcurrentlyStatus.RECONSUME_LATER;
+            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
         });
 
         defaultMQPushConsumer.start();