This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new ad13fe38 Remove useless heartbeat success log prints (#740)
ad13fe38 is described below
commit ad13fe38278831c93717370d7675ad2f4d3c36f2
Author: weihubeats <[email protected]>
AuthorDate: Fri Jun 14 18:36:00 2024 +0800
Remove useless heartbeat success log prints (#740)
* Remove useless heartbeat success log prints
* Change the log level to debug
* update doHeartbeat log to debug
---
golang/client.go | 2 +-
golang/client_manager.go | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/golang/client.go b/golang/client.go
index 9f60e061..a51c4cc6 100644
--- a/golang/client.go
+++ b/golang/client.go
@@ -437,7 +437,7 @@ func (cli *defaultClient) doHeartbeat(target string,
request *v2.HeartbeatReques
Message: resp.GetStatus().GetMessage(),
}
}
- cli.log.Infof("send heartbeat successfully, endpoints=%v", endpoints)
+ cli.log.Debugf("send heartbeat successfully, endpoints=%v", endpoints)
switch p := cli.clientImpl.(type) {
case *defaultProducer:
if _, ok := p.isolated.LoadAndDelete(target); ok {
diff --git a/golang/client_manager.go b/golang/client_manager.go
index 99655afb..6930174e 100644
--- a/golang/client_manager.go
+++ b/golang/client_manager.go
@@ -147,7 +147,7 @@ func (cm *defaultClientManager) clearIdleRpcClients() {
}
}
func (cm *defaultClientManager) doHeartbeat() {
- sugarBaseLogger.Info("clientManager start doHeartbeat")
+ sugarBaseLogger.Debug("clientManager start doHeartbeat")
cm.clientTable.Range(func(_, v interface{}) bool {
client := v.(*defaultClient)
client.Heartbeat()
