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

        // stop the Connect cluster and its backing Kafka cluster.
        connect.stop();
    }
An example integration test that demonstrates how to setup an integration test for Connect.
<p></p>
The following test configures and executes up a sink connector pipeline in a worker, produces messages into
the source topic-partitions, and demonstrates how to check the overall behavior of the pipeline.
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ExampleConnectIntegrationTest.java