Skip to content

Commit

Permalink
Fix debug message to show actual SQS message ID (elastic#20614)
Browse files Browse the repository at this point in the history
  • Loading branch information
kaiyan-sheng authored Sep 29, 2020
1 parent c9827a8 commit a29dcc2
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 a29dcc2

Please sign in to comment.