Merge pull request #987 from humkum/reduce-log-level

[ISSUE #986]Reduce the log level when fetch offset success and remove unnecessary mq
apache · Feb 8, 2023 · 757e639 · 757e639
2 parents 896a8a3 + cfb845b
commit 757e639
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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,