synchronized void addSubscribedTopicsFromMetadata(final Set<String> topics, final String logPrefix) {
        if (usesPatternSubscription() && !subscriptionUpdates().equals(topics)) {
            updateSubscribedTopics(topics, logPrefix);
        }
    }
Returns the topic names for any optimized source changelogs
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java