@Test
void startTimeAfter() {

    Instant now = Instant.now();
    domainBuilder.topicMessage(t -> t.consensusTimestamp(now.minusNanos(1))).block();
    TopicMessageFilter filter = TopicMessageFilter.builder()
            .startTime(now)
            .build();
    pollingTopicMessageRetriever.retrieve(filter)
            .as(StepVerifier::create)
            .expectNextCount(0)
            .thenCancel()
            .verify(Duration.ofMillis(500));
}