public <T> Mono<T> insertOrGet(T record) {
        return mongoClient.insert(record)
                .thenReturn(record)
                .onErrorResume(DuplicateKeyException.class,
                        e -> mongoClient.findOne(record.getClass())
                                .switchIfEmpty((Mono) insertOrGet(record)));
    }
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