protected void unassignPartitions(Collection<TopicPartition> partitionsToUnassign) {
    Collection<TopicPartition> newAssignment = new HashSet<>(consumer.assignment());
    newAssignment.removeAll(partitionsToUnassign);
    consumer.assign(newAssignment);
  }
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