apache-kafka - Apache Kafka MirrorMaker 2 - 访问目标集群中的状态存储更改日志

Question

在 Active-Active MM2 (MirrorMaker 2) 设置中，我有以下数据中心 (DC1,DC2)：

直流1：

有主题 T1

Kafka Streams 应用程序从 T1 消费并更新本地状态存储（例如：“MyStateStore”）。applicationId 是“myapp”。

DC2：

有主题 T1

MM2 进程将来自 DC1 中源 T1 的记录复制到 DC2 数据中心中的 DC1.T1 中。MM2 还将 myapp-MyStateStore-changelog 从 DC1 复制到 DC2 中的 DC1.myapp-MyStateStore-changelog。

MM2配置：

“sync.group.offsets.enabled = true”。

问题 ：

• 当我将“myapp”故障转移到 DC2 时，应用程序将如何访问 State Store？在我的代码中，我只能指定要从中使用的 statestore 的名称。
• 有没有办法让我也可以访问目标站点（DC2）中的 State Store？

我的理论是，在 DC2 中，只有名为 DC1.myapp-MyStateStore-changelog 的更改日志主题中有记录，因此当我将 myapp 故障转移到 DC2 时，所有状态都基本上丢失了。