diff --git a/src/main/java/dbtucker/connect/kinesis/KinesisSinkTask.java b/src/main/java/dbtucker/connect/kinesis/KinesisSinkTask.java
index e0363d8..89c24cf 100644
--- a/src/main/java/dbtucker/connect/kinesis/KinesisSinkTask.java
+++ b/src/main/java/dbtucker/connect/kinesis/KinesisSinkTask.java
@@ -181,7 +181,7 @@ private void retryPutRecords(String streamName, List<PutRecordsRequestEntry> ent
               final PutRecordsRequestEntry putRecordRequestEntry = entries.get(i);
               final PutRecordsResultEntry putRecordsResultEntry = putRecordsResultEntryList.get(i);
               if (putRecordsResultEntry.getErrorCode() != null) {
-                  log.error("putRecords returned error: (" + putRecordsResultEntry.getErrorCode() + ") " + putRecordsResultEntry.getErrorMessage());
+                  log.debug("putRecords returned error: (" + putRecordsResultEntry.getErrorCode() + ") " + putRecordsResultEntry.getErrorMessage());
                   failedRecordsList.add(putRecordRequestEntry);
               }
           }