diff --git a/flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriter.java b/flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriter.java
index 15cd799..6cfa607 100644
--- a/flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriter.java
+++ b/flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriter.java
@@ -220,9 +220,8 @@
         }
 
         LOG.warn(
-                "KDF Sink failed to write and will retry {} entries to KDF first request was {}",
+                "KDF Sink failed to write and will retry {} entries to KDF",
                 requestEntries.size(),
-                requestEntries.get(0).toString(),
                 err);
         requestResult.accept(requestEntries);
     }
@@ -238,10 +237,8 @@
             return;
         }
 
-        LOG.debug(
-                "KDF Sink failed to write and will retry {} entries to KDF first request was {}",
-                requestEntries.size(),
-                requestEntries.get(0).toString());
+        LOG.warn(
+                "KDF Sink failed to write and will retry {} entries to KDF", requestEntries.size());
         List<Record> failedRequestEntries = new ArrayList<>(response.failedPutCount());
         List<PutRecordBatchResponseEntry> records = response.requestResponses();
 
diff --git a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java
index 58d3d8a..684d018 100644
--- a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java
+++ b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java
@@ -231,7 +231,7 @@
             Throwable err,
             List<PutRecordsRequestEntry> requestEntries,
             Consumer<List<PutRecordsRequestEntry>> requestResult) {
-        LOG.debug(
+        LOG.warn(
                 "KDS Sink failed to write and will retry {} entries to KDS",
                 requestEntries.size(),
                 err);
@@ -251,7 +251,7 @@
             PutRecordsResponse response,
             List<PutRecordsRequestEntry> requestEntries,
             Consumer<List<PutRecordsRequestEntry>> requestResult) {
-        LOG.debug(
+        LOG.warn(
                 "KDS Sink failed to write and will retry {} entries to KDS",
                 response.failedRecordCount());
         numRecordsOutErrorsCounter.inc(response.failedRecordCount());