diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
index 00dcb36cb5446f81dcb387de891ea70faba64cd1..ab93573061c0f50241f3e38b97a6a48849e1c0fb 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
@@ -2121,7 +2121,6 @@ public class MQClientAPIImpl {
 
         RemotingCommand response = this.remotingClient.invokeSync(address, request, timeoutMillis);
         assert response != null;
-        System.out.println("create retry topic for consumerGrouop: " + consumerGroup);
         if (ResponseCode.SUCCESS != response.getCode()) {
             throw new MQClientException(response.getCode(), response.getRemark());
         }
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
index 7f1496bdbbfdd5209545a0e735cf45eefe3ee9f9..2f6ec2884676e7ebc57b8f1fac3c1f4161ffaf70 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
@@ -1284,7 +1284,6 @@ public class MQClientInstance {
 
     public void createRetryTopic(String topic,
         String consumerGroup) {
-        System.out.println("****create retry topic for consumerGrouop: " + consumerGroup);
         TopicRouteData topicRouteData = this.topicRouteTable.get(topic);
         if (topicRouteData != null) {
             if (topicRouteData.getBrokerDatas() != null) {