@Override
        public void init(final ProcessorContext<String, String> context) {
            this.context = context;
        }
A processor that simply forwards all messages to all children.
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java