protected long getStoppingOffset(TopicPartition tp) {
    return stoppingOffsets.getOrDefault(tp, Long.MAX_VALUE);
  }
A {@link SplitReader} implementation that reads records from Kafka partitions.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/internals/KafkaPartitionSplitReader.java