change log level

jessecollier · Aug 17, 2017 · e0ff940 · e0ff940
1 parent 336cfc9
commit e0ff940
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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);
               }
           }