This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new ffd7241 [feat] fix query not found (#886)
ffd7241 is described below
commit ffd724165ee59b9108191b8fee72ec78f8535214
Author: Xuexue <[email protected]>
AuthorDate: Sun Aug 7 15:31:43 2022 +0800
[feat] fix query not found (#886)
---
consumer/offset_store.go | 5 +++++
internal/response.go | 1 +
2 files changed, 6 insertions(+)
diff --git a/consumer/offset_store.go b/consumer/offset_store.go
index 86ecd18..83639b8 100644
--- a/consumer/offset_store.go
+++ b/consumer/offset_store.go
@@ -372,6 +372,11 @@ func (r *remoteBrokerOffsetStore)
fetchConsumeOffsetFromBroker(group string, mq
if err != nil {
return -1, err
}
+
+ if res.Code == internal.ResQueryNotFount {
+ return -1, nil
+ }
+
if res.Code != internal.ResSuccess {
return -2, fmt.Errorf("broker response code: %d, remarks: %s",
res.Code, res.Remark)
}
diff --git a/internal/response.go b/internal/response.go
index ae75b9c..4ead63a 100644
--- a/internal/response.go
+++ b/internal/response.go
@@ -27,6 +27,7 @@ const (
ResPullNotFound = int16(19)
ResPullRetryImmediately = int16(20)
ResPullOffsetMoved = int16(21)
+ ResQueryNotFount = int16(22)
)
type SendMessageResponse struct {
