v1.1.1
-
Fix
PollingRecordPublisherto respectSHARD_GETRECORDS_INTERVAL_MILLIS. (pull request) (Apache Flink JIRA) -
Update EFO consumer error handling to treat Interrupted exceptions as non-recoverable. (pull request) (Apache Flink JIRA)
Fix PollingRecordPublisher to respect SHARD_GETRECORDS_INTERVAL_MILLIS. (pull request) (Apache Flink JIRA)
Update EFO consumer error handling to treat Interrupted exceptions as non-recoverable. (pull request) (Apache Flink JIRA)