Apache Pulsar复制订阅相关的二三事

在 Pulsar 里,可以基于 geo-replication 将数据在多个机房进行复制,这个特性主要是复制的消息数据,而今天我们分享的主要是订阅状态的跨机房同步。 订阅状态主要指订阅的消费进度,开启订阅状态跨机房复制可以在其中某个机房出现故障时,consumer 切换其他机房可以根据消费进度继续进行消费,这样可以减少消息的重复消费以及consumer丢失消息的问题。