Я использую Apache в качестве рамки Samza для Kafka, и мне нужно разделить одно и то же хранилище ключей с ключом RockDBs между двумя задачами.Я использую одно и то же хранилище для хранения ключей (RockDBs) в двух разных StreamTask одновременно?
Я могу сделать это, не имея параллелизма при хранении. Значение ключа?
Я развернул 2 задачи с тем же хранилищем для ключей и он работает.
Так что да, мы можем.
Начиная с Samza 0.12.0 нет поддерживаемого способа совместного использования хранилищ между задачами. Каждое хранилище создается (изолировано) для каждой задачи.
Для получения дополнительной информации, смотрите раздел «Местное государство» здесь: http://samza.apache.org/learn/documentation/0.12/container/state-management.html