Is there any such API on the consumer or the producer that I can use to
check for the underlying connection to the kafka brokers from my producer?
I need to ping Kafka broker every minute and check if there is a connection
available? Any suggestions?

Reply via email to