Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅
中国的 Amazon Web Services 服务入门
(PDF)。
本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
您可以按计划进行故障转移,以测试应用程序在包含源MSK集群的主 Amazon 区域发生意外事件时的弹性。计划的故障转移不应导致数据丢失。
关闭所有连接到您的源集群的生成器和使用器。
创建新的 MSK Replicator,将数据MSK从辅助区域的MSK集群复制到主区域中的集群。这是将要写入二级区域的数据复制回主区域所必需的,这样您就可以在意外事件结束后对主区域执行失效自动恢复。
在辅助 Amazon 区域的目标集群上启动生产者。
请按照以下选项卡之一的步骤操作,具体取决于应用程序的消息排序要求。
- No message ordering
如果您的应用程序不需要消息排序,请使用通配符运算符(例如,topic
)在辅助 Amazon 区域中启动从本地(例如)和复制主题(例如<sourceKafkaClusterAlias>.topic
)读取内容的使用者。 *主题)。
- Message ordering
-
如果您的应用程序需要消息排序,则仅为目标集群上复制的主题(例如 <sourceKafkaClusterAlias>.topic
)启动使用器,而不为本地主题(例如 topic
)启动使用器。
等待目标MSK集群上所有已复制主题的使用者完成所有数据的处理,这样使用者延迟为 0,处理的记录数也为 0。然后,停止目标集群上已复制主题的使用器。此时,从源MSK集群复制到目标MSK集群的所有记录都已消耗。
在目标MSK集群上启动本地主题(例如topic
)的使用者。