@Test
void missingTopicID() {

    ConsensusTopicQuery query = ConsensusTopicQuery.newBuilder().build();
    grpcConsensusService.subscribeTopic(Mono.just(query))
            .as(StepVerifier::create)
            .expectErrorSatisfies(t -> assertException(t, Status.Code.INVALID_ARGUMENT, "Missing required topicID"))
            .verify(Duration.ofMillis(500));
}