public Position positionFromString()

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]));
    }