in org.apache.aries.events.kafka/src/main/java/org/apache/aries/events/kafka/KafkaMessaging.java [152:158]
public Position positionFromString(String position) {
String[] chunks = position.split(":");
if (chunks.length != 2) {
throw new IllegalArgumentException(format("Illegal position format %s", position));
}
return new KafkaPosition(parseInt(chunks[0]), parseLong(chunks[1]));
}