@AfterEach
    public void close() {
        // stop the Connect workers and Kafka brokers.
        connect.stop();
    }
Integration test for the creation of internal topics.
connect/runtime/src/test/java/org/apache/kafka/connect/integration/InternalTopicsIntegrationTest.java