0

我目前正在探索 MM2 实现,并且在受身份验证保护的两个集群之间设置集群复制时遇到了真正的麻烦。

我无法找到 mm2 身份验证配置的任何文档或示例,最后我尝试在类似于以下内容的 conf 中映射常用的 jaas 属性:

# clusters
clusters = source, target
source.bootstrap.servers=clusterone.mydomain.org:9092
target.bootstrap.servers=clustertwo.mydomain.org:9092
## source JaaS config
source.kafka.security.protocol=SASL_SSL
source.kafka.sasl.mechanism=PLAIN
source.kafka.sasl.jaas.config=<SECRET>
## target JaaS config
target.kafka.security.protocol=SASL_SSL
target.kafka.sasl.mechanism=PLAIN
target.kafka.sasl.jaas.config=<SECRET>
## mm2 sync config
topics= .*
...

不幸的是,这并没有奏效。

因此,如果您有关于与 security/jaas 属性相关的文档的指针或用于身份验证访问的 mm2 conf 的工作示例,我将不胜感激。

先感谢您

4

0 回答 0