I am using Flink 1.13.1 on AWS EMR and I seem to have hit this bug: https://issues.apache.org/jira/browse/FLINK-27041. My job will fail when there are empty partitions. I see it is fixed in a newer version of Flink but I cannot update Flink version at this time.
Suggestions on a workaround? I am looking at trying to subclass the KafkaPartitionSplitReader to include the changes from the PR https://github.com/apache/flink/pull/19456/files. But it is not intended to be subclassed.
