@AfterEach
    public void close() {
        // delete connector handle
        RuntimeHandles.get().deleteConnector(CONNECTOR_NAME);

        // stop the Connect cluster and its backing Kafka cluster.
        connect.stop();
    }
An integration test for connectors with transformations
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.java