@Override
  protected KafkaPartitionSplitState initializedState(KafkaPartitionSplit split) {
    if (logReadHelper != null) {
      logReadHelper.initializedState(split);
    }
    return new LogKafkaPartitionSplitState(split);
  }
The source reader for Kafka partitions.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/source/log/kafka/LogKafkaSourceReader.java