From cfb845b1980f15759afa9fce08320686cd396ff9 Mon Sep 17 00:00:00 2001
From: Hankunming <1109939087@qq.com>
Date: Sat, 28 Jan 2023 13:15:49 +0800
Subject: [PATCH] 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 842d0405..0fa748c9 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,