private static Map<Partition, Long> parseOffsetList(String topic, String offsetList) throws IllegalArgumentException {
		Assert.hasText(offsetList, "must contain a list of values");
		Assert.isTrue(VALIDATION_PATTERN.matcher(offsetList).matches(), "must be in the form 0@20");
		Map<Partition, Long> partitionNumbers = new HashMap<Partition, Long>();
		String[] partitionOffsetPairs = offsetList.split(",");
		for (String partitionOffsetPair : partitionOffsetPairs) {
			String[] split = partitionOffsetPair.split("@");
			partitionNumbers.put(new Partition(topic, Integer.parseInt(split[0])), Long.parseLong(split[1]));
		}
		return partitionNumbers;
	}
Parses the list of initial offsets and creates a map to initialize the {@link OffsetManager}

@author Marius Bogoevici
@author Ilayaperumal Gopinathan
extensions/spring-xd-extension-kafka/src/main/java/org/springframework/integration/x/kafka/InitialOffsetsFactoryBean.java