fix log prints

apache · Apr 23, 2024 · ce70fee · ce70fee
1 parent 4d414ca
commit ce70fee
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -519,7 +519,7 @@ func (pc *pushConsumer) messageQueueChanged(topic string, mqAll, mqDivided []*pr
 				newVal = 1
 			}
 			rlog.Info("The PullThresholdForQueue is changed", map[string]interface{}{
-				rlog.LogKeyValueChangedFrom: pc.option.PullThresholdForTopic,
+				rlog.LogKeyValueChangedFrom: pc.option.PullThresholdForQueue.Load(),
 				rlog.LogKeyValueChangedTo:   newVal,
 			})
 			pc.option.PullThresholdForQueue.Store(int64(newVal))