From 2358ec3d9098d9de7822b22fe8d8146741c37de8 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 18 May 2023 15:04:11 +0800 Subject: [PATCH] get seqs --- pkg/common/db/cache/msg.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pkg/common/db/cache/msg.go b/pkg/common/db/cache/msg.go index 99dfe46b4..bd4b2772c 100644 --- a/pkg/common/db/cache/msg.go +++ b/pkg/common/db/cache/msg.go @@ -137,7 +137,10 @@ func (c *msgCache) getSeqs(ctx context.Context, items []string, getkey func(s st if seq.Err() != nil && seq.Err() != redis.Nil { return nil, errs.Wrap(v.Err()) } - m[items[i]] = utils.StringToInt64(seq.Val()) + seqInt64 := utils.StringToInt64(seq.Val()) + if seqInt64 != 0 { + m[items[i]] = seqInt64 + } } return m, nil }