@Test
void greaterThanPageSize() {

    int maxPageSize = retrieverProperties.getMaxPageSize();
    retrieverProperties.setMaxPageSize(2);
    domainBuilder.topicMessage().block();
    domainBuilder.topicMessage().block();
    domainBuilder.topicMessage().block();
    TopicMessageFilter filter = TopicMessageFilter.builder()
            .startTime(Instant.EPOCH)
            .build();
    pollingTopicMessageRetriever.retrieve(filter)
            .map(TopicMessage::getSequenceNumber)
            .as(StepVerifier::create)
            .expectNext(1L, 2L, 3L)
            .expectComplete()
            .verify(Duration.ofMillis(500));
    retrieverProperties.setMaxPageSize(maxPageSize);
}