You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Otis Gospodnetić <ot...@gmail.com> on 2015/11/05 02:45:55 UTC

Best way to watch for leader changes?

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/