Verifique se o sistema está conectado ao Kafka

Preciso escrever um teste de fumaça em Java que valide se o sistema está conectado ao kafka,

Alguém tem alguma ideia? Eu encontrei este post:

Como verificar se o Kafka Server está sendo executado?

Mas é muito complicado fazer isso a partir de um código Java e não acho que seja a direção que devo usar.

Desde já, obrigado.

questionAnswers(2)

yourAnswerToTheQuestion