@BeforeAll
    public static void startCluster() throws IOException, InterruptedException {
        CLUSTER.start();
        CLUSTER.createTopics(DEFAULT_INPUT_TOPIC, DEFAULT_INPUT_TABLE_TOPIC);
    }
Tests related to internal topics in streams
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java