Greetings, I have general design question i did not see addressed in the docs. Basically how does samza guarantee a single writer for each changelog partition. Because of strong ordering assumption of these changelog, how do you protect against zombie processes writing to the changelog with out of date values.
Thanks, John
