A FLIP-27 implementation of the Flink Kinesis Streams Source
This is in development, do not use! Feel free to contribute :D
Navigate to KinesisStreamsSourceExample
and run the main method from IntelliJ.
A FLIP-27 implementation of the Flink Kinesis Streams Source
JavaApache-2.0