Hi all, I noticed in the javadocs that SplitReaders should not have a blocking handleSplitsChanges implementation: https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/splitreader/SplitReader.java#L55
However, for KafkaPartitionSplitReader, the implementation is blocking due to potential IO to retrieve committed offsets. I just wanted to double check: is this javadoc accurate or should the KafkaPartitionSplitReader implementation be optimized? Best, Mason
