@Override
                    public void init(final ProcessorContext context) {
                        System.out.println("[0.10.1] initializing processor: topic=data taskId=" + context.taskId());
                        numRecordsProcessed = 0;
                    }
This test cannot be executed, as long as Kafka 0.10.1.2 is not released
streams/upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java