Hi, In Kafka 0.8 Simple Consumer https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example shows how to watch for leader changes and find a new one:
if (fetchResponse.hasError()) {
// go find new leader
// ...
Is this still the recommended way of finding new leaders in 0.9?
Thanks,
Otis
--
Monitoring - Log Management - Alerting - Anomaly Detection
Solr & Elasticsearch Consulting Support Training - http://sematext.com/
