@Override
                    public void punctuate(final long timestamp) {}
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