amazon-kinesis-connector-flink
amazon-kinesis-connector-flink copied to clipboard
awslabs
This is a fork of the Apache Flink Kinesis connector adding Enhanced Fanout support for Flink 1.8/1.11 on KDA.
Backport the following fixes from Apache Flink 1.13.6 release - [[FLINK-18363] Add user classloader to context in DeSerializationSchema](https://github.com/apache/flink/commit/da67eeb90dda7d6610c5328f061ab417a5c4edbc) - [[FLINK-21913][table][connectors] Update DynamicTableFactory.Context](https://github.com/apache/flink/commit/73338e22bd0567169ce2636c8f9e3b87df783385) - [[hotfix][tests] Move containsCause to FlinkMatchers](https://github.com/apache/flink/commit/7ea887f86e96cc10eb461b73b9d0761b5720bc8a) By submitting...
AWS Kinesis Stream read from different account fails after upgrade to flink-connector-kinesis 1.15.2
I have a AWS Kinesis Analytics application Java project (Runtime Apache Flink 1.13, with flink-connector-kinesis 1.13.2) that consumes a Kinesis Stream from a different account. It was setup using this...
I used flink-1.12.5 kinesis connector to consume data from kinesis. And flink-1.12.5 should have all the latest features in `amazon-kinesis-connector-flink` repo. From time to time I am getting IOException or...
SequenceNumber class is currently part of the "Kinesis-Stream-Shard-State", but it does not follow requirements of POJO compatible type. Because of that we are getting warning like this: ``` TypeExtractor -...
Hello, We are experiencing issues while using flink with AWS SSO authent to consume a kinesis stream (we don't have problem when using directly KCL, KPL or KDS SDK native...
