1

consume/ad_original_data_application.go

@@ -44,7 +44,6 @@ func AdOriginalDataApplication(queue md.MqQueue) {
 			fmt.Println("err ::: ", err)
 			if err != nil {
 				fmt.Println("AdOriginalDataApplication_ERR:::::", err.Error())
-				_ = res.Reject(true) //TODO::拒绝 Ack
 				//_ = res.Reject(false)
 				var canalMsg *md2.ZhiosAdOriginalDataApplication
 				var tmpString string