@Override
    public synchronized void put(TaskStatus status) {
        if (status.state() == TaskStatus.State.DESTROYED)
            tasks.remove(status.id().connector(), status.id().task());
        else
            tasks.put(status.id().connector(), status.id().task(), status);
    }
An implementation of StatusBackingStore that stores statuses in-memory.
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java