Sample showcasing the use of FlinkKinesisConsumer with EFO support - View it on GitHub