Github user tzulitai commented on a diff in the pull request:
@@ -218,6 +232,8 @@ public void invoke(OUT value, Context context) throws
throw new RuntimeException("Kinesis producer has been
--- End diff --
This second check is to check any async errors that occurred during the
queue flush, correct?
If so, we should probably move this second invocation into
`checkQueueLimit` to make this more implicit.