in src/main/java/org/apache/sling/distribution/journal/kafka/KafkaClientProvider.java [183:185]
public String assignTo(long offset) { return format("%s:%s", PARTITION, offset); }