"This is only possible through SimpleConsumer right now."
Is that correct? Did you mean SimpleConsumer or HighLevelConsumer? What
are the differences?
On 12/8/11 8:53 AM, Jun Rao wrote:
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?
