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

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

按计划向辅助 Amazon 区域执行故障转移

您可以按计划进行故障转移,以测试应用程序在包含源MSK集群的主 Amazon 区域发生意外事件时的弹性。计划的故障转移不应导致数据丢失。

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

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

  3. 在辅助 Amazon 区域的目标集群上启动生产者。

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

No message ordering

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

Message ordering

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

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

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