@Override
    public synchronized TaskStatus get(ConnectorTaskId id) {
        return tasks.get(id.connector(), id.task());
    }
An implementation of StatusBackingStore that stores statuses in-memory.
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java