@Override
    public void stop() {
        // Worker offset store should not be stopped as it may be used for multiple connectors
        connectorStore.ifPresent(OffsetBackingStore::stop);
        connectorStoreAdmin.ifPresent(TopicAdmin::close);
    }
If configured to use a connector-specific offset store, {@link OffsetBackingStore#stop() stop} that store,
and {@link TopicAdmin#close(Duration) close} the topic admin used by that store.

<p>The worker-global offset store is not modified as it may be used for other connectors that either already exist,
or will be created, on this worker.
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java