public <T> Flux<ChangeStreamDocument<T>> subscribe(
            Class<T> collectionClass,
            FullDocument fullDocument) {
        // Don't use the filter of watch because the code like
        // "filter(Criteria.where(clusterIdFieldName).is(clusterId))"
        // cannot work if it is a delete operation
        return mongoClient.watch(collectionClass, fullDocument);
    }
Note that only listen to the change in the same cluster
turms-server-common/src/main/java/im/turms/server/common/infra/cluster/service/config/SharedConfigService.java