Polish the log

apache · Aug 8, 2023 · 98032fd · 98032fd
1 parent 3a6ef04
commit 98032fd
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 6 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java b/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
@@ -654,9 +654,9 @@ public void registerSingleTopicAll(
                     try {
                         RemotingCommand response = BrokerOuterAPI.this.remotingClient.invokeSync(namesrvAddr, request, timeoutMills);
                         assert response != null;
-                        LOGGER.info("Register single topic %s to broker %s with response code %s", topic, brokerName, response.getCode());
+                        LOGGER.info("Register single topic {} to broker {} with response code {}", topic, brokerName, response.getCode());
                     } catch (Exception e) {
-                        LOGGER.warn(String.format("Register single topic %s to broker %s exception", topic, brokerName), e);
+                        LOGGER.warn("Register single topic {} to broker {} exception", topic, brokerName, e);
                     } finally {
                         countDownLatch.countDown();
                     }
@@ -722,10 +722,10 @@ public void run0() {
                                 default:
                                     break;
                             }
-                            LOGGER.warn("Query data version from name server {} OK, changed {}, broker {},name server {}", namesrvAddr, changed, topicConfigWrapper.getDataVersion(), nameServerDataVersion == null ? "" : nameServerDataVersion);
+                            LOGGER.warn("Query data version from name server {} OK, changed {}, broker {}, name server {}", namesrvAddr, changed, topicConfigWrapper.getDataVersion(), nameServerDataVersion == null ? "" : nameServerDataVersion);
                         } catch (Exception e) {
                             changedList.add(Boolean.TRUE);
-                            LOGGER.error("Query data version from name server {}  Exception, {}", namesrvAddr, e);
+                            LOGGER.error("Query data version from name server {} exception", namesrvAddr, e);
                         } finally {
                             countDownLatch.countDown();
                         }

diff --git a/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java b/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java
@@ -49,7 +49,8 @@ public static void main(String[] args) throws MQClientException {
          * }
          * </pre>
          */
-        consumer.setNamesrvAddr(DEFAULT_NAMESRVADDR);
+        // Uncomment the following line while debugging, namesrvAddr should be set to your local address
+        // consumer.setNamesrvAddr(DEFAULT_NAMESRVADDR);
 
         /*
          * Specify where to start in case the specific consumer group is a brand-new one.

diff --git a/example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java b/example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java
@@ -54,7 +54,7 @@ public static void main(String[] args) throws MQClientException, InterruptedExce
          * </pre>
          */
         // Uncomment the following line while debugging, namesrvAddr should be set to your local address
-        producer.setNamesrvAddr(DEFAULT_NAMESRVADDR);
+        // producer.setNamesrvAddr(DEFAULT_NAMESRVADDR);
 
         /*
          * Launch the instance.