diff --git a/api/v1/sqs/aws-sqs.go b/api/v1/sqs/aws-sqs.go index 20ff78d..b0a0b9b 100644 --- a/api/v1/sqs/aws-sqs.go +++ b/api/v1/sqs/aws-sqs.go @@ -201,7 +201,8 @@ func processMessage(svc *sqs.SQS, queueURL string, msg *sqs.Message) { zap.Int64("receiveCount", receiveCount)) // 解析失败时不删除消息,让它自动重新变为可见,实现重复消费 // 通过将可见性超时设为 0,立即让消息重新变为可见 - changeMessageVisibility(svc, queueURL, msg, 0) + // changeMessageVisibility(svc, queueURL, msg, 0) + deleteMessage(svc, queueURL, msg) return }