Hi, I recently switched from FlinkKinesisConsumer to KinesisStreamsSource as advised in the docs: https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kinesis/#kinesis-consumer
Since this migration we have a lot more ReadProvisionedThroughputExceeded warnings in CloudWatch. >From what I found in the documentation and in the source code there is no way to configure a polling interval while in the FlinkKinesisConsumer there is a possibility to configure this. How can we avoid that the GetRecords is called continuously? Note that this Kinesis stream is also used by other readers based on the Kinesis Client lib. Our current code to setup the Source is similar to what is in the code sample on https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kinesis/#kinesis-streams-sink Any help is much appreciated. Kind regards, Jeroen