Hello Flink Community! I'm currently coding on a project relying on AWS Kinesis. With the provided connector (flink-connector-kinesis_2.11;1.10.0), I can consume the message.
But as the main stream is used among several other teams, I was required to use the enhance fanout of Kinesis. I checked the connector code and found no implementations. Has this issue occurred to anyone before? Thanks for your help.