@Test
void startTimeBefore() {

    domainBuilder.topicMessages(10, Instant.now()).blockLast();
    TopicMessageFilter filter = TopicMessageFilter.builder()
            .startTime(Instant.EPOCH)
            .build();
    pollingTopicMessageRetriever.retrieve(filter)
            .map(TopicMessage::getSequenceNumber)
            .as(StepVerifier::create)
            .expectNext(1L, 2L, 3L, 4L, 5L, 6L, 7L, 8L, 9L, 10L)
            .thenCancel()
            .verify(Duration.ofMillis(1000));
}