Update persistence.go

2 months ago · cd2264ffc7
1 changed files with 2 additions and 1 deletions
--- 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
 }