fix pullThresholdSizeForTopic invalid (#814)

* fix pullThresholdSizeForTopic invalid * fix code style Co-authored-by: longjunhu <hulongjun@douyu.tv> Co-authored-by: dinglei <libya_003@163.com>
apache · Jul 21, 2022 · d802a4d · d802a4d
1 parent db78506
commit d802a4d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -451,6 +451,7 @@ func (pc *pushConsumer) messageQueueChanged(topic string, mqAll, mqDivided []*pr
 				rlog.LogKeyValueChangedFrom: pc.option.PullThresholdSizeForTopic,
 				rlog.LogKeyValueChangedTo:   newVal,
 			})
+			pc.option.PullThresholdSizeForTopic = newVal
 		}
 	}
 	pc.client.SendHeartbeatToAllBrokerWithLock()