Hi all, We're trying to make our Kafka consumers fail fast, rather than run forever. We're using Kubernetes to run our containers, and we are taking a fail fast approach, and letting K8s manage restarts.
What I want to happen 1) Start my consumer. This connects to Kafka 2) Kill my Kafka cluster to cause a connection failure 3) Kafka consumer fails on the call to .poll() What actually happens 1) Start my consumer. This connects to Kafka 2) Kill my Kafka cluster to cause a connection failure 3) Kafka consumer just prints log messages, and no exception is ever thrown. I can't seem to find how to modify this behavior in the consumer properties documentation. Is it possible, and if so, what settings do I tweak? Thanks, Todd
