@Override
        public Processor<String, Long, String, Long> get() {
            return new CustomMaxAggregator();
        }
This is code sample in docs/streams/developer-guide/testing.html
streams/examples/src/test/java/org/apache/kafka/streams/examples/docs/DeveloperGuideTesting.java