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

Reply via email to