public Mono<Void> upsert(Filter filter, Update update, Object entity) {
        return mongoClient.updateOne(entity.getClass(), filter, update)
                .flatMap(updateResult -> updateResult.getMatchedCount() == 0
                        ? mongoClient.insert(entity)
                                .onErrorResume(DuplicateKeyException.class,
                                        e -> this.upsert(filter, update, entity))
                        : Mono.empty());
    }
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