@Test
void timeout() {

    int maxPageSize = retrieverProperties.getMaxPageSize();
    Duration timeout = retrieverProperties.getTimeout();
    retrieverProperties.setMaxPageSize(1);
    retrieverProperties.setTimeout(Duration.ofMillis(10));
    domainBuilder.topicMessages(10, Instant.now()).blockLast();
    TopicMessageFilter filter = TopicMessageFilter.builder()
            .startTime(Instant.EPOCH)
            .build();
    pollingTopicMessageRetriever.retrieve(filter)
            .map(TopicMessage::getSequenceNumber)
            .as(StepVerifier::create)
            .thenConsumeWhile(i -> true)
            .expectTimeout(Duration.ofMillis(500))
            .verify();
    retrieverProperties.setMaxPageSize(maxPageSize);
    retrieverProperties.setTimeout(timeout);
}