From d027f970e36d802017a7b26dbd81cd72eff75540 Mon Sep 17 00:00:00 2001 From: chrislu Date: Thu, 27 Feb 2025 01:18:47 -0800 Subject: [PATCH] avoid wrongly set startPosition --- weed/mq/topic/local_partition.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/weed/mq/topic/local_partition.go b/weed/mq/topic/local_partition.go index e32fc2398..d1433775a 100644 --- a/weed/mq/topic/local_partition.go +++ b/weed/mq/topic/local_partition.go @@ -89,12 +89,16 @@ func (p *LocalPartition) Subscribe(clientName string, startPosition log_buffer.M return nil } - startPosition = processedPosition + if processedPosition.Time.UnixNano() != 0 { + startPosition = processedPosition + } processedPosition, isDone, readInMemoryLogErr = p.LogBuffer.LoopProcessLogData(clientName, startPosition, 0, onNoMessageFn, eachMessageFn) if isDone { return nil } - startPosition = processedPosition + if processedPosition.Time.UnixNano() != 0 { + startPosition = processedPosition + } if readInMemoryLogErr == log_buffer.ResumeFromDiskError { continue