我想在创建时在所有主题中使用自定义复制因子。我正在运行 7 节点群集,我想将 5 设置为我所有主题的复制因子。
Kafka Connect 连接器无法使用自定义设置创建自己的主题。这是KIP-158计划改进的东西。
就目前的情况(Apache Kafka 2.4(而言,连接器只能依赖于使用默认复制因子等自动创建它们的代理(如果auto.create.topics.enable=true
(,或者您可以预先创建它们并在此时设置所需的复制因子。