更新

consume/canal_guide_order_by_user_up_lv_consume.go

@@ -37,7 +37,6 @@ func CanalGuideOrderByUserUpLvConsume(queue md.MqQueue) {
 			handleCanalGuideOrderByUserUpLvConsume(res.Body)
 			//_ = res.Reject(false)
 			//_ = res.Ack(true)
-			_ = res.Ack(true)
 		} else {
 			panic(errors.New("error getting message"))
 		}