@SuppressWarnings("unchecked")
    public <K, V> ProcessorContext<K, V> setCurrentNodeForProcessorContext(final String processorName) {
        final ProcessorContext<K, V> context = task.processorContext();
        ((ProcessorContextImpl) context).setCurrentNode(getProcessor(processorName));
        return context;
    }
Get the processor context, setting the processor whose name is given as current node

@param processorName processor name to set as current node
@return the processor context
streams/src/test/java/org/apache/kafka/streams/TopologyTestDriverWrapper.java