remove log

apache · Sep 7, 2023 · 2686759 · 2686759
1 parent 4154eb7
commit 2686759
Showing 1 changed file with 0 additions and 2 deletions.
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
@@ -158,11 +158,9 @@ public MQClientInstance(ClientConfig clientConfig, int instanceIndex, String cli
                 private final ConcurrentMap<String, HashMap<Long, String>> brokerAddrTable = MQClientInstance.this.brokerAddrTable;
                 @Override
                 public void onChannelConnect(String remoteAddr, Channel channel) {
-                    log.info("onChannelConnect {}", remoteAddr);
                     for (Map.Entry<String, HashMap<Long, String>> addressEntry : brokerAddrTable.entrySet()) {
                         for (String address : addressEntry.getValue().values()) {
                             if (address.equals(remoteAddr)) {
-                                log.info("onChannelConnect {} send heartbeat", remoteAddr);
                                 sendHeartbeatToAllBrokerWithLockV2(false);
                                 break;
                             }