@Override
        public void init(final ProcessorContext<String, String> context) {
            this.context = context;
        }
A processor that removes custom timestamp information from messages and forwards modified messages to each child.
A message contains custom timestamp information if the value is in ".*@[0-9]+" format.
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java