@Override
        public void process(final Record<String, String> record) {
            context.forward(record.withValue(record.value().split("@")[0]));
        }
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