Hi Pedro,
Thanks for reaching out.
A Samza app using KVStores can expect read-your-writes guarantee because
a. in the failure free case, rocksdb provides that, and b. in case of
failures, samza resumes input (and state) consumption
from the last complete checkpoint (at which everything written to
We created SEP-23: Simplify Job Runner, which simplifies job runner by
moving config retrieval and planning to AM.
Please find out the SEP wiki below:
https://cwiki.apache.org/confluence/display/SAMZA/SEP-23%3A+Simplify+Job+Runner
Please take a look and chime in your thoughts.
Thanks,
Ke
