kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sachin Kale <sachinpk...@gmail.com>
Subject Detecting cluster down in consumer
Date Mon, 11 Nov 2019 11:54:44 GMT

We are working on a prototype where we write to two Kafka cluster
(primary-secondary) and read from one of them (based on which one is
primary) to increase the availability. There is a flag which is used to
determine which cluster is primary and other becomes secondary. On
detecting primary cluster is down, secondary is promoted to primary.

How do we detect cluster downtime failures in Kafka Consumer? I tried
different things but poll() makes sure to mask all the exceptions and
returns 0 records.


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message