При использовании kafka с samza, samza автоматически создает определенные темы, такие как контрольная точка, координатор и журнал изменений, используя имена из файла свойств. Но эти темы создаются в одном кластере.
Но для целей обслуживания я хочу создать их в отдельном кластере, возможно ли это?
Да. Вы можете настроить систему для каждого кластера и установить значения для task.checkpoint.system, job.coordinatior.system и stores.<storename>.changelog, чтобы каждый из них указывал на другой кластер/систему.
Вот документация по настройке для справки: http://samza.apache.org/learn/documentation/0.11/jobs/configuration-table.html
