in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java [188:190]
public String assignTo(Reset reset, long relativeOffset) { return format("%s:%s:%d", PARTITION, reset.name(), relativeOffset); }