From cd2264ffc79fc38510e87dbb80431c3967367d08 Mon Sep 17 00:00:00 2001 From: chrislu Date: Fri, 12 Sep 2025 21:23:04 -0700 Subject: [PATCH] Update persistence.go --- weed/mq/kafka/offset/persistence.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/weed/mq/kafka/offset/persistence.go b/weed/mq/kafka/offset/persistence.go index 4c1256e2c..2a43fafe0 100644 --- a/weed/mq/kafka/offset/persistence.go +++ b/weed/mq/kafka/offset/persistence.go @@ -189,5 +189,6 @@ func (pl *PersistentLedger) GetLatestOffset() int64 { // GetStats returns statistics about the ledger func (pl *PersistentLedger) GetStats() (count int, earliestTime, latestTime int64) { - return pl.Ledger.GetStats() + count, _, earliestTime, latestTime = pl.Ledger.GetStats() + return count, earliestTime, latestTime }