当使用带有 samza 的 kafka 时，samza 会使用属性文件中的名称自动创建某些主题，例如检查点、co-oridnator 和更改日志。但是这些主题是在同一个集群中创建的。
但是出于维护目的，我想在单独的集群中创建它们，可以吗？
问问题
176 次
1 回答
1
是的。您可以为每个集群配置一个系统并设置 的值
task.checkpoint.system，以便它们中的每一个都指向不同的集群/系统。job.coordinatior.systemstores.<storename>.changelog
这是供参考的配置文档：http: //samza.apache.org/learn/documentation/0.11/jobs/configuration-table.html
于 2016-11-22T01:42:18.270 回答