将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