I have a springboot microservice that listens to a couple of topics. When the microservice starts up I would like to quickly (5->10 seconds) determine if a kafka broker is unavailable. I am able to see this work with a kafka console consumer but am having a hard time getting Java (spring-kafka) to reproduce the speedy turnaround. With java, Kafka seems to be honoring a 60000 ms TimeoutException.
Is there a way I can quickly determine a successful connection? Thank you.
