public Set<String> sourceTopicChangelogs() {
            return sourceTopics.stream().filter(stateChangelogTopics::containsKey).collect(Collectors.toSet());
        }
Returns the topic names for any optimized source changelogs
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java