commit 97419746b0d93e9b06d9453b9c39910861e3de1b
author xujianhai666 <52450794+xujianhai666@users.noreply.github.com> Sun Sep 06 21:53:50 2020 +0800
committer GitHub <noreply@github.com> Sun Sep 06 21:53:50 2020 +0800
tree 7ed6de26d8c7dc207a64d391bd94c542b2cc5c0a
parent 3d5dab0405228dda740554a04ab06263e8e99e7d
parent f904a3f82de1df8e0ebf1441b4ab028375306059

Merge pull request #531 from xujianhai666/fix-apache-retry

[ISSUE #530] fix: initialize 0 for retry topic when ConsumeFromLastOffst

consumer/consumer.go

diff --git a/consumer/consumer.go b/consumer/consumer.go
index 3129b8d..0a2f6d0 100644
--- a/consumer/consumer.go
+++ b/consumer/consumer.go
@@ -754,7 +754,7 @@
 		case ConsumeFromLastOffset:
 			if lastOffset == -1 {
 				if strings.HasPrefix(mq.Topic, internal.RetryGroupTopicPrefix) {
-					lastOffset = 0
+					result = 0
 				} else {
 					lastOffset, err := dc.queryMaxOffset(mq)
 					if err == nil {