Removed console print in client

apache · Feb 11, 2019 · 806f36b · 806f36b
1 parent 0e4aa3a
commit 806f36b
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
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
@@ -2121,7 +2121,6 @@ public void createRetryTopic(final String address, final String enodeName,
 
         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
@@ -1284,7 +1284,6 @@ public Map<MessageQueue, Long> getConsumerStatus(String topic, String group) {
 
     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) {