@Test
void jsonError() {

    TopicMessageFilter filter = TopicMessageFilter.builder()
            .startTime(Instant.EPOCH)
            .build();
    // Parsing errors will be logged and ignored and the message will be lost
    topicListener.listen(filter)
            .as(StepVerifier::create)
            .thenAwait(Duration.ofMillis(50))
            .then(() -> jdbcTemplate.execute("NOTIFY topic_message, 'invalid'"))
            .expectNoEvent(Duration.ofMillis(500L))
            .thenCancel()
            .verify(Duration.ofMillis(600L));
}