我们已经设置了 MirrorMaker 来跨两个 Kafka 集群复制消息。我们还设置exclude.internal.topic=false
了镜像制造商消费者属性来复制内部主题。我假设这也将复制__consumer_offset topic
,这将反过来同步辅助集群中的消费者组偏移量。
但是当我们在辅助集群中启动消费者组时,它从一开始就开始消费消息,所以看起来消费者组偏移量没有在辅助集群中复制。
谁能提供一些建议,我们如何使用 MirrorMaker 或任何其他解决方案同步辅助集群中的消费者组偏移量?