public SourceNode<?, ?> source() {
        return source;
    }
Returns the corresponding source node in the topology

@return SourceNode
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java