@EventListener
        public void handleKafkaMessagePublishedEvent(final KafkaMessagePublishedEvent event) throws Exception {
            val messageReceived = latch.await(5, TimeUnit.SECONDS);
            Assert.isTrue(messageReceived, "Kafka message could not be received");
        }
This is {@link KafkaTicketRegistryTests}.

@author Misagh Moayyed
@since 5.2.0
support/cas-server-support-kafka-ticket-registry/src/test/java/org/apereo/cas/ticket/registry/KafkaTicketRegistryTests.java