Skip to content

Commit 41bb61b

Browse files
authored
Log the error message from SQS when failing to send a message to the SQS queue. (#6143)
Signed-off-by: David Venable <dlv@amazon.com>
1 parent a4db6da commit 41bb61b

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

  • data-prepper-plugins/sqs-sink/src/main/java/org/opensearch/dataprepper/plugins/sink/sqs

data-prepper-plugins/sqs-sink/src/main/java/org/opensearch/dataprepper/plugins/sink/sqs/SqsSinkBatch.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,8 @@
66
package org.opensearch.dataprepper.plugins.sink.sqs;
77

88
import org.opensearch.dataprepper.model.event.Event;
9+
import org.slf4j.Logger;
10+
import org.slf4j.LoggerFactory;
911
import software.amazon.awssdk.services.sqs.model.BatchResultErrorEntry;
1012
import org.opensearch.dataprepper.model.codec.OutputCodec;
1113
import org.opensearch.dataprepper.model.sink.OutputCodecContext;
@@ -30,7 +32,10 @@
3032
import java.util.UUID;
3133
import java.util.function.BiConsumer;
3234

35+
import static org.opensearch.dataprepper.logging.DataPrepperMarkers.NOISY;
36+
3337
public class SqsSinkBatch {
38+
private static final Logger LOG = LoggerFactory.getLogger(SqsSinkBatch.class);
3439
public static final int MAX_MESSAGES_PER_BATCH = 10;
3540
public static final int MAX_BATCH_SIZE_BYTES = 256*1024;
3641
private static final String SQS_FIFO_SUFFIX = ".fifo";
@@ -227,6 +232,7 @@ public boolean flushOnce() {
227232
sinkMetrics.recordRequestSize((double)requestSize);
228233

229234
} catch (SqsException e) {
235+
LOG.error(NOISY, "Failed to send messages to SQS: {}", e.getMessage());
230236
sinkMetrics.incrementRequestsFailedCounter(1);
231237
sinkMetrics.incrementEventsFailedCounter(entries.size());
232238
if (!isRetryableException(e)) {

0 commit comments

Comments
 (0)