From 68cd0e6c5afe4cd63331b6976fbf0ffb0e97e976 Mon Sep 17 00:00:00 2001
From: zhouxiang <zhouxiang.zzx@alibaba-inc.com>
Date: Thu, 7 Sep 2023 15:29:16 +0800
Subject: [PATCH] remove log

---
 .../apache/rocketmq/client/impl/factory/MQClientInstance.java   | 2 --
 1 file changed, 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
index 2551ddb68a3..f9b7950e12d 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
@@ -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;
                             }