pingles / clj-kafka

Wrapper to the Java API for interacting with Kafka
Eclipse Public License 1.0
211 stars 77 forks source link

how to handle zk disconnect #88

Open clojurians-org opened 7 years ago

clojurians-org commented 7 years ago

the kafka (messages (consumers) method report: "Failed to find leader for Set" when the zookeeper is disconnect. i can't find the method to reconnect the zookeeper, as i can't pass any watch int it.