[feat] fix query not found (#886)

aireet · web-flow · commit ffd724165ee5 · 2022-08-07T15:31:43.000+08:00
diff --git 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
@@ -27,6 +27,7 @@ const (
 	ResPullNotFound         = int16(19)
 	ResPullRetryImmediately = int16(20)
 	ResPullOffsetMoved      = int16(21)
+	ResQueryNotFount        = int16(22)
 )
 
 type SendMessageResponse struct {

Original file line number	Diff line number	Diff line change
`@@ -372,6 +372,11 @@ func (r *remoteBrokerOffsetStore) fetchConsumeOffsetFromBroker(group string, mq`
`372`	`372`	`if err != nil {`
`373`	`373`	`return -1, err`
`374`	`374`	`}`
	`375`	`+`
	`376`	`+ if res.Code == internal.ResQueryNotFount {`
	`377`	`+ return -1, nil`
	`378`	`+ }`
	`379`	`+`
`375`	`380`	`if res.Code != internal.ResSuccess {`
`376`	`381`	`return -2, fmt.Errorf("broker response code: %d, remarks: %s", res.Code, res.Remark)`
`377`	`382`	`}`
Original file line number	Diff line number	Diff line change
`@@ -27,6 +27,7 @@ const (`
`27`	`27`	`ResPullNotFound = int16(19)`
`28`	`28`	`ResPullRetryImmediately = int16(20)`
`29`	`29`	`ResPullOffsetMoved = int16(21)`
	`30`	`+ ResQueryNotFount = int16(22)`
`30`	`31`	`)`
`31`	`32`
`32`	`33`	`type SendMessageResponse struct {`