Hi: I am using multiple (almost 30 and growing) Flink streaming applications that read from the same kinesis stream and get ProvisionedThroughputExceededException exception which fails the job.
I have seen a reference http://mail-archives.apache.org/mod_mbox/flink-user/201811.mbox/%3CCAJnSTVxpuOhCNTFTvEYd7Om4s=q2vz5-8+m4nvuutmj2oxu...@mail.gmail.com%3E - which indicates there might be some solution perhaps in Flink 1.8/1.9. I also see [FLINK-10536] Flink Kinesis Consumer leading to job failure due to ProvisionedThroughputExceededException - ASF JIRA is still open. So i wanted to find out 1. If this issue has been resolved and if so in which version ?2. Is there any kinesis consumer with kinesis fanout available that can help address this issue ?3. Is there any specific parameter in kinesis consumer config that can address this issue ? If there is any other pointer/documentation/reference, please let me know. Thanks
