执行迁移到二级 Amazon 区域的计划失效转移 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

执行迁移到二级 Amazon 区域的计划失效转移

您可以开展计划的失效转移,以测试应用程序在具有源 MSK 集群的主 Amazon 区域发生意外事件时的弹性。计划失效转移不应导致数据丢失。

如果使用相同主题名称复制配置,请按照以下步骤操作:

  1. 关闭所有连接到您的源集群的生成器和使用器。

  2. 创建一个新的 MSK 复制器,将数据从辅助区域中的 MSK 集群复制到主区域中的 MSK 集群,并使用相同主题名称复制(控制台中为保留相同的主题名称)。这是将要写入二级区域的数据复制回主区域所必需的,这样您就可以在意外事件结束后对主区域执行失效自动恢复。

  3. 启动连接到辅助 Amazon 区域中的目标集群的生产者和消费者。

如果使用带前缀主题名称配置,请按照以下步骤进行失效转移:

  1. 关闭所有连接到您的源集群的生成器和使用器。

  2. 创建新的 MSK 复制器,将数据从二级区域的 MSK 集群复制到主区域中的 MSK 集群。这是将要写入二级区域的数据复制回主区域所必需的,这样您就可以在意外事件结束后对主区域执行失效自动恢复。

  3. 在二级 Amazon 区域的目标集群上启动生成器。

  4. 请按照以下选项卡之一的步骤操作,具体取决于应用程序的消息排序要求。

    No message ordering

    如果您的应用程序不需要消息排序,请使用通配符运算符(例如)在辅助 Amazon 区域中启动从本地(例如主题<sourceKafkaClusterAlias>.topic)和复制主题(例如.*topic)读取内容的消费者。

    Message ordering

    如果您的应用程序需要消息排序,则仅为目标集群上复制的主题(例如 <sourceKafkaClusterAlias>.topic)启动使用器,而不为本地主题(例如 topic)启动使用器。

  5. 等待目标 MSK 集群上所有已复制主题的使用器完成所有数据的处理,这样使用器延迟为 0,而处理的记录数也为 0。然后,停止目标集群上已复制主题的使用器。此时,从源 MSK 集群复制到目标 MSK 集群的所有记录都已使用。

  6. 在目标 MSK 集群上启动本地主题(例如 topic)的使用器。