Skip to content

Commit

Permalink
Fix debug message to show actual SQS message ID (#20614) (#21398)
Browse files Browse the repository at this point in the history
(cherry picked from commit a29dcc2)
  • Loading branch information
kaiyan-sheng authored Sep 30, 2020
1 parent 340348a commit ba654e1
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion x-pack/filebeat/input/s3/input.go
Original file line number Diff line number Diff line change
Expand Up @@ -288,7 +288,7 @@ func (p *s3Input) processorKeepAlive(svcSQS sqsiface.ClientAPI, message sqs.Mess
// When ACK done, message will be deleted. Or when message is
// not s3 ObjectCreated event related(handleSQSMessage function
// failed), it will be removed as well.
p.logger.Debug("Deleting message from SQS: ", message.MessageId)
p.logger.Debug("Deleting message from SQS: ", *message.MessageId)
// only delete sqs message when errC is closed with no error
err := p.deleteMessage(queueURL, *message.ReceiptHandle, svcSQS)
if err != nil {
Expand Down

0 comments on commit ba654e1

Please sign in to comment.