[rocketmq-client-go] branch master updated: [ISSUE #942] Fix response ResQueryNotFound typo (#948)

[yuzhou]

This is an automated email from the ASF dual-hosted git repository.

yuzhou 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 5779439  [ISSUE #942] Fix response ResQueryNotFound typo (#948)
5779439 is described below

commit 5779439374cdaeccc6f47ee8af9c99edbc34a9f8
Author: Jack Wong <jackwong3...@yahoo.com>
AuthorDate: Sat Oct 22 21:42:37 2022 +0800

    [ISSUE #942] Fix response ResQueryNotFound typo (#948)
    
    Co-authored-by: jack.wong <jack.w...@bytedance.com>
---
 consumer/offset_store.go | 2 +-
 internal/response.go     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/consumer/offset_store.go b/consumer/offset_store.go
index 83639b8..842d040 100644
--- a/consumer/offset_store.go
+++ b/consumer/offset_store.go
@@ -373,7 +373,7 @@ func (r *remoteBrokerOffsetStore) 
fetchConsumeOffsetFromBroker(group string, mq
                return -1, err
        }
 
-       if res.Code == internal.ResQueryNotFount {
+       if res.Code == internal.ResQueryNotFound {
                return -1, nil
        }
 
diff --git a/internal/response.go b/internal/response.go
index 4ead63a..d1c7e18 100644
--- a/internal/response.go
+++ b/internal/response.go
@@ -27,7 +27,7 @@ const (
        ResPullNotFound         = int16(19)
        ResPullRetryImmediately = int16(20)
        ResPullOffsetMoved      = int16(21)
-       ResQueryNotFount        = int16(22)
+       ResQueryNotFound        = int16(22)
 )
 
 type SendMessageResponse struct {