Я запускаю приложение samza (id-1), которое использует несколько тем Kafka (topic1, topic2, topic3) и смещение контрольной точки в теме контрольной точки kafka, соответствующей этому приложению.Теперь я хочу запустить новое приложение samza (id-2), которое потребляет только Kafka topic2 и хочу, чтобы application1 прекратило использовать эту тему.Я хочу, чтобы это новое приложение (id-2) начало потреблять со смещения, где приложение 1. отметило контрольную точку.
Поскольку samza создает тему контрольной точки для каждого приложения отдельно, так, как я сообщаю моему новому приложению смещение, которое оно должно использоватьfrom.
Я думаю переместить данные темы контрольной точки из старой темы контрольной точки в новую тему контрольной точки, но не уверен, что это правильный подход?