protected void recordActiveTopic(String topic) {
        if (statusBackingStore.getTopic(id.connector(), topic) != null) {
            // The topic is already recorded as active. No further action is required.
            return;
        }
        statusBackingStore.put(new TopicStatus(topic, id, time.milliseconds()));
    }
Include this topic to the set of active topics for the connector that this worker task
is running. This information is persisted in the status backing store used by this worker.

@param topic the topic to mark as active for this connector
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java