@BeforeAll
    public static void startCluster() throws IOException {
        CLUSTER.start();
    }
Tests local state store and global application cleanup.
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java