@Override
    public void clear() {
        keyValMap.clear();
    }
ConcurrentHashSet, construct the set collection through ConcurrentHashMap
 to complete the operation management of the concurrent set
inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/utils/ConcurrentHashSet.java