@AfterAll
    public static void closeCluster() throws IOException {
        CLUSTER.stop();
    }
Test the unclean shutdown behavior around state store cleanup.
streams/src/test/java/org/apache/kafka/streams/integration/EOSUncleanShutdownIntegrationTest.java