Hi, I need to manage geo-redundancy in my Kafka cluster across zones. I am planning to do this with Apache Mirror Maker to maintain an active-passive site. I wanted to understand consumer and producer failover when the primary cluster fails. Is there any way to detect and failover Flink's Kafka source and sink to secondary Kafka brokers? And of course, to bring the source and sink back to primary once it's available? Thank youChirag
