将kafka与samza一起使用时，samza使用属性文件中的名称自动创建某些主题，如checkpoint、co oridnator和changelog。但是这些主题是在同一个集群中创建的。但是出于维护的目的，我想在一个单独的集群中创建它们，可以吗？
sq1bmfud1#
对。您可以为每个集群配置一个系统，并设置 task.checkpoint.system , job.coordinatior.system 以及 stores.<storename>.changelog 所以它们每个都指向不同的集群/系统。以下是供参考的配置文档：http://samza.apache.org/learn/documentation/0.11/jobs/configuration-table.html
task.checkpoint.system
job.coordinatior.system
stores.<storename>.changelog
1条答案
按热度按时间sq1bmfud1#
对。您可以为每个集群配置一个系统，并设置
task.checkpoint.system,job.coordinatior.system以及stores.<storename>.changelog所以它们每个都指向不同的集群/系统。以下是供参考的配置文档：http://samza.apache.org/learn/documentation/0.11/jobs/configuration-table.html