public void close() {
        logger.info("Stopping connector '" + name + "'");
        taskRunner.stop();
        sourceConnector.stop();
        destroyTopic();
        logger.info("Connector '" + name + "' stopped");
    }
@Test
    public void should_cleanup_on_destroy() {
        Properties properties = dummySourceConnectorProperties();
        properties.setProperty(ITEMS_SIZE, String.valueOf(3));
        var wrapper = new TestSourceConnectorWrapper(properties);
        assertThat(sourceConnectorInstance().isStarted()).isTrue();

        wrapper.close();

        assertThat(sourceConnectorInstance().isStarted()).isFalse();
    }