diff --git a/platformapi/jcqapi/jcqapi.go b/platformapi/jcqapi/jcqapi.go index ac8051ad..d65489ec 100644 --- a/platformapi/jcqapi/jcqapi.go +++ b/platformapi/jcqapi/jcqapi.go @@ -132,7 +132,7 @@ type ConsumeInfoResult struct { //消费信息 //https://docs.jdcloud.com/cn/message-queue/consume-message -func (a *API) ConsumeInfo(topic, consumerGroupId string, size int) (consumeInfoResult *ConsumeInfoResult, err error) { +func (a *API) ConsumeInfo(topic, consumerGroupId string, size int) (consumeInfoResult []*ConsumeInfoResult, err error) { result, err := a.AccessAPI("v1/messages", httpURL, map[string]interface{}{ "topic": topic, "consumerGroupId": consumerGroupId,