in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkTask.java [233:239]
private void checkForEarlierPutException() { if (putException != null) { final ConnectException e = putException; putException = null; throw e; } }