public Map<Integer, Long> getPartitionPositions(final String topic) {
        final ConcurrentHashMap<Integer, Long> bound = position.get(topic);
        return bound == null ? Collections.emptyMap() : Collections.unmodifiableMap(bound);
    }
Return the partition -&gt; offset mapping for a specific topic.
streams/src/main/java/org/apache/kafka/streams/query/Position.java