public List<ConsumerGroupMeta> getAllConsumerGroupMeta() {
    return StreamSupport.stream(
            consumerGroupMetaKeeper.getAllConsumerGroupMeta().spliterator(), false)
        .collect(Collectors.toList());
  }
Caller should ensure that the method is called in the lock {@link #acquireWriteLock}.
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/subscription/SubscriptionInfo.java