docs: private List<KafkaTopicPartitionState<KPH>> createPartitionStateHolders(
  		List<KafkaTopicPartition> partitions,
  		long initialOffset,
  		int timestampWatermarkMode,
  		SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic,
  		SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated,
  		ClassLoader userCodeClassLoader) throws IOException, ClassNotFoundException {
  
  		Map<KafkaTopicPartition, Long> partitionsToInitialOffset = new HashMap<>(partitions.size());
  		for (KafkaTopicPartition partition : partitions) {
  			partitionsToInitialOffset.put(partition, initialOffset);
  		}
  
  		return createPartitionStateHolders(
  				partitionsToInitialOffset,
  				timestampWatermarkMode,
  				watermarksPeriodic,
  				watermarksPunctuated,
  				userCodeClassLoader);
  	}