public TSStatus handleConsumerGroupMetaChanges(ConsumerGroupHandleMetaChangePlan plan) {
    acquireWriteLock();
    try {
      LOGGER.info("Handling consumer group meta changes ...");

      consumerGroupMetaKeeper.clear();

      plan.getConsumerGroupMetaList()
          .forEach(
              consumerGroupMeta -> {
                consumerGroupMetaKeeper.addConsumerGroupMeta(
                    consumerGroupMeta.getConsumerGroupId(), consumerGroupMeta);
                LOGGER.info("Recording consumer group meta: {}", consumerGroupMeta);
              });

      return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
    } finally {
      releaseWriteLock();
    }
  }
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