Как прослушать несколько коллекций, используя поток изменений весной

Question

Я хочу собирать данные в коллекцию collection_one, collection_two, collection_three и т.д., как мне это сделать?

       ChangeStreamRequest request = ChangeStreamRequest.builder().collation(Collation.of("collection_one"))
            .filter(Aggregation.newAggregation(match(where("operationType").exists(true))))
            .publishTo(krakenDtoMessageListener)
            .build();
    container.register(request, CollectionOne.class);

Должен ли я создать несколько changeStreamRequest или все должно быть в порядке?