How to check health of the cluster (like Ping() method)

[mostafatalebi]

We have a producer that produces millions of messages per minute to Kafka.
And we receive reports of messages asynchronously.
I would like to know if is there a mechanism to check health of the cluster, like a Ping() function, which if it returns err constantly for a given duration, we stop producing messages and block the process.