@Override
    public synchronized Collection<TaskStatus> getAll(String connector) {
        return new HashSet<>(tasks.row(connector).values());
    }
An implementation of StatusBackingStore that stores statuses in-memory.
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java