У меня есть задание samza с рядом задач, каждая из которых содержит некоторое состояние в своем встроенном хранилище. Я хочу предоставить доступ к этому хранилищу для чтения внешнему миру через какой-то механизм RPC. Что может быть лучшим решением...

Мой вариант использования — идентифицировать объекты, от которых ожидаемые события не были получены по прошествии X времени в режиме реального времени, а не с использованием пакетных заданий. Например: Если мы получили событие PaymentInitiated в...

Мой вариант использования — идентифицировать сущности, от которых ожидаемые события не были получены по прошествии X времени в режиме реального времени. Например: если мы получили событие PaymentInitiated в момент времени T, но не получили ни...

У кого-нибудь Samza работает с менеджером ресурсов в HA? Если да, то что мне установить yarn.resourcemanager.hostname в yarn-site.xml ? Если я установлю его на первый из моих RM, отправка задания будет работать нормально, если я отправлю...

Мне нужно найти, где Samza на YARN размещает свои государственные магазины KV. Я подозреваю, что он находится в локальном каталоге приложений YARN, как и все приложения YARN, но я считаю, что его можно настроить, поскольку я сделал это несколько...