@AfterEach
    public void close() {
        RuntimeHandles.get().deleteConnector(CONNECTOR_NAME);
        connect.stop();
    }
Integration test for the different error handling policies in Connect (namely, retry policies, skipping bad records,
and dead letter queues).
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ErrorHandlingIntegrationTest.java