@Test
void constraintViolationException() {

    ConsensusTopicQuery query = ConsensusTopicQuery.newBuilder()
            .setTopicID(TopicID.newBuilder().build())
            .setLimit(-1)
            .build();
    grpcConsensusService.subscribeTopic(Mono.just(query))
            .as(StepVerifier::create)
            .expectErrorSatisfies(t -> assertException(t, Status.Code.INVALID_ARGUMENT, "limit: must be greater " +
                    "than or equal to 0"))
            .verify(Duration.ofMillis(500));
}