Hi All, I am running Flink jobs in AWS Managed Fl...
# random
s
Hi All, I am running Flink jobs in AWS Managed Flink. The streaming application consumes data from three Kafka topics, performs joins and windowing operations, and stores the results in an output Kafka topic. Since Kafka is running in an active-active mode, the offsets differ between regions. How can I rebuild the state to restart jobs in a failover region? Given that this is a tier-1 application, I need to set up failover jobs in an alternate region. What options are available for rebuilding or synchronizing Flink state?