private Admin createAdminClient() {
        final Properties adminClientConfig = new Properties();
        adminClientConfig.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, CLUSTER.bootstrapServers());
        return Admin.create(adminClientConfig);
    }
Tests related to internal topics in streams
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java