public String getStoreForChangelogTopic(final String topicName) {
        for (final InternalTopologyBuilder builder : builders.values()) {
            final String store = builder.getStoreForChangelogTopic(topicName);
            if (store != null) {
                return store;
            }
        }
        log.warn("Unable to locate any store for topic {}", topicName);
        return "";
    }
@return the {@link ProcessorTopology subtopology} built for this task, guaranteed to be non-null

@throws UnknownTopologyException  if the task is from a named topology that this client isn't aware of
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java