Hi, 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. -Sachin-
