Hello all, I was reading through the Samza paper ( http://www.vldb.org/pvldb/vol10/p1634-noghabi.pdf, very nicely written by the way), and in the section on fault-tolerance I noticed that the changelog is implemented with read-your-writes guarantees. Knowing that this changelog is a Kafka stream, I cannot find any information on whether Kafka provides read-your-writes guarantees.
Intuitively, since producers and consumers are separate entities I would expect this guarantee to not exist: a process acting as both a producer and consumer, which executes a produce() followed by a poll() is not guaranteed to read the produced record immediately. So, how is the read-your-writes changelog implemented? Regards, Pedro Silvestre
