v1.1.2

Release 1.1.2 (May 27th, 2021)

• Backport Fix issue where KinesisDataFetcher.shutdownFetcher() hangs. (issue, pull request)

• Backport - Log error when shutting down Kinesis Data Fetcher. (issue, pull request)

• Backport - Treating TimeoutException as Recoverable Exception. (issue, pull request)

• Backport - Add time-out for acquiring subscription and passing events from network to source thread to prevent deadlock. (pull request)

v2.0.3

• Fix issue where KinesisDataFetcher.shutdownFetcher() hangs. (issue, pull request)

• Log error when shutting down Kinesis Data Fetcher. (issue, pull request)

• Treating TimeoutException as Recoverable Exception. (issue, pull request)

• Adding a SQL connector module for SQL client. (pull request)

v2.0.2

• Add time-out for acquiring subscription and passing events from network to source thread to prevent deadlock. (pull request)

v2.0.1

• 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)

v1.1.1

• 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)

v2.0.0

• Add KDS connector support in the Table API and SQL layer.
  (pull request)

v1.1.0

• Migrate EFO consumers to use DescribeStreamSummary rather than DescribeStream. DescribeStreamSummary has a
  higher TPS quota, resulting in reduced startup time for high parallelism sources. You may need add IAM permission for
  kinesis:DescribeStreamSummary while upgrading to this version
  (pull request)

• Fix issue preventing DynamoDB stream consumers to start from LATEST
  (pull request,
  issue)

v1.0.4

Fix issue when Polling consumer using timestamp with empty shard

v1.0.3

Optimisation to clone deserialisation schema once per shard consumer, rather than once per record

v1.0.2

Optimising error handling and retry policy for high backpressure workloads