@Override
    public void put(final TopicStatus status) {
        topics.computeIfAbsent(status.connector(), k -> new ConcurrentHashMap<>())
                .put(status.topic(), status);
    }
An implementation of StatusBackingStore that stores statuses in-memory.
connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java