Skip to content

Commit cd6c9c0

Browse files
authored
Update push_consumer.go
解决打印日志时发生的崩溃问题。
1 parent f07155b commit cd6c9c0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

consumer/push_consumer.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -516,7 +516,7 @@ func (pc *pushConsumer) pullMessage(request *PullRequest) {
516516
"PullThresholdForQueue": pc.option.PullThresholdForQueue,
517517
"minOffset": pq.Min(),
518518
"maxOffset": pq.Max(),
519-
"count": pq.msgCache,
519+
"count": pq.cachedMsgCount,
520520
"size(MiB)": cachedMessageSizeInMiB,
521521
"flowControlTimes": pc.queueFlowControlTimes,
522522
rlog.LogKeyPullRequest: request.String(),
@@ -533,7 +533,7 @@ func (pc *pushConsumer) pullMessage(request *PullRequest) {
533533
"PullThresholdSizeForQueue": pc.option.PullThresholdSizeForQueue,
534534
"minOffset": pq.Min(),
535535
"maxOffset": pq.Max(),
536-
"count": pq.msgCache,
536+
"count": pq.cachedMsgCount,
537537
"size(MiB)": cachedMessageSizeInMiB,
538538
"flowControlTimes": pc.queueFlowControlTimes,
539539
rlog.LogKeyPullRequest: request.String(),

0 commit comments

Comments
 (0)