先不消费

This commit is contained in:
苏尹岚
2020-07-30 16:31:30 +08:00
parent d380080e3b
commit 92136bd93f

View File

@@ -137,7 +137,7 @@ func (a *API) ConsumeInfo(topic, consumerGroupId string, size int) (consumeInfoR
"topic": topic,
"consumerGroupId": consumerGroupId,
"size": size,
"ack": "true", //默认消费之后就确认
// "ack": "true", //默认消费之后就确认
})
if err == nil {
utils.Map2StructByJson(result["result"].(map[string]interface{})["messages"], &consumeInfoResult, false)