[rocketmq-client-go] branch master updated: reduce the log level when fetch offset success and remove unnecessary mq

[cserwen]

This is an automated email from the ASF dual-hosted git repository.

cserwen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new cfb845b  reduce the log level when fetch offset success and remove 
unnecessary mq
     new 757e639  Merge pull request #987 from humkum/reduce-log-level
cfb845b is described below

commit cfb845b1980f15759afa9fce08320686cd396ff9
Author: Hankunming <1109939...@qq.com>
AuthorDate: Sat Jan 28 13:15:49 2023 +0800

    reduce the log level when fetch offset success and remove unnecessary mq
---
 consumer/offset_store.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/consumer/offset_store.go b/consumer/offset_store.go
index 842d040..0fa748c 100644
--- a/consumer/offset_store.go
+++ b/consumer/offset_store.go
@@ -285,7 +285,7 @@ func (r *remoteBrokerOffsetStore) remove(mq 
*primitive.MessageQueue) {
        defer r.mutex.Unlock()
 
        delete(r.OffsetTable, *mq)
-       rlog.Warning("delete mq from offset table", map[string]interface{}{
+       rlog.Info("delete mq from offset table", map[string]interface{}{
                rlog.LogKeyConsumerGroup: r.group,
                rlog.LogKeyMessageQueue:  mq,
        })
@@ -322,7 +322,7 @@ func (r *remoteBrokerOffsetStore) readWithException(mq 
*primitive.MessageQueue,
                        r.mutex.RUnlock()
                        return -1, err
                }
-               rlog.Warning("fetch offset of mq from broker success", 
map[string]interface{}{
+               rlog.Info("fetch offset of mq from broker success", 
map[string]interface{}{
                        rlog.LogKeyConsumerGroup: r.group,
                        rlog.LogKeyMessageQueue:  mq.String(),
                        "offset":                 off,