@Override
    public Collection<TopicStatus> getAllTopics(String connector) {
        ConcurrentMap<String, TopicStatus> activeTopics = topics.get(Objects.requireNonNull(connector));
        return activeTopics != null
               ? Collections.unmodifiableCollection(activeTopics.values())
               : Collections.emptySet();
    }
An implementation of StatusBackingStore that stores statuses in-memory.
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java