Mark, Today, this is mostly the responsibility of the consumer, by managing the offsets properly. For example, if the consumer periodically flushes messages to disk, it has to checkpoint to disk the offset corresponding to the last flush. On failure, the consumer has to rewind the consumption from the last checkpointed offset. This is only possible through SimpleConsumer right now.
Thanks, Jun On Thu, Dec 8, 2011 at 8:18 AM, Mark <static.void....@gmail.com> wrote: > How can one guarantee exactly one semantics when using Kafka as a > traditional queue? Is this guarantee the responsibility of the consumer? >
