public ProcessorNode<?, ?, ?, ?> getProcessor(final String name) {
        for (final ProcessorNode<?, ?, ?, ?> node : processorTopology.processors()) {
            if (node.name().equals(name)) {
                return node;
            }
        }
        for (final ProcessorNode<?, ?, ?, ?> node : globalTopology.processors()) {
            if (node.name().equals(name)) {
                return node;
            }
        }
        throw new StreamsException("Could not find a processor named '" + name + "'");
    }
Get a processor by name

@param name the name to search for
@return the processor matching the search name
streams/src/test/java/org/apache/kafka/streams/TopologyTestDriverWrapper.java