在主动式-被动式卡夫卡集群架构中创建卡夫卡主题

Question

我试图找出在被动的卡夫卡集群体系结构中创建一个主题的正确方法。

假设我们在两个分离的可用区域中有两个Kafka集群(主动式和被动式)。我理解，当数据从主动集群复制到被动集群时，就会发生主题镜像。

问题是。当我创建一个主题时，应该分别在两个集群上创建它吗？如果不是，那么镜像制造者应该知道在活动集群上是否有一个新的主题，并在被动集群上创建它的副本。

如有任何澄清，不胜感激

Answer 1

KMM2 (至少)监视源集群中的Kafka主题。

详细地看一下KM对找出使用管理的频率、要复制的主题以及它是如何涉及到同步它们的配置的。

KMM代码非常简单，因此在需要时分叉和进行更改应该不会太困难(但是很有可能通过设置策略/params获得您想要的东西)。