We are having two Kafka clusters in two region as active passive mode. During active cluster failure, the consumer binding need to change to passive cluster without restart. We are using spring cloud stream and function. Kindly suggest