我知道可以为 kafka 流配置复制因子这些内部主题，我们的应用程序用于复制因子为 3 的普通应用程序主题，但到目前为止我还没有为变更日志/重新分区主题配置复制因子，而我的假设是如果一个经纪人死亡（或由于某种原因领导者发生变化），kafka 流应用程序将自动重新平衡到新的领导者。
现在，如果内部主题不使用复制因子，我不太确定正在运行的 Kafka Stream 应用程序是否可以重新平衡到新的领导者。
我们是否也应该对这些内部主题使用复制因子 3？
谢谢各位的解答....
是的，您需要对更改日志/重新分区主题使用应用程序主题的相同复制因子。
您可以通过指定更改日志/重新分区主题的复制因子
properties.put(StreamsConfig.REPLICATION_FACTOR_CONFIG, 3)
哈特哈，
账单
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
