@Override
        public void process(final Record<String, String> record) {
            context.forward(record.withTimestamp(record.timestamp() + 10));
        }
A processor that simply forwards all messages to all children with advanced timestamps.
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java