@AfterAll
    public static void closeCluster() {
        CLUSTER.stop();
    }
Tests related to internal topics in streams
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java