kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chia-Chun Shih <chiachun.s...@gmail.com>
Subject consumer ack for high-level consumer?
Date Wed, 05 Nov 2014 06:42:29 GMT
Hi,

I am a new to Kafka. In my understanding, high-level consumer (
ZookeeperConsumerConnector) changes offset when message is drawn
by ConsumerIterator. But I would like to change offset when message is
processed, not when message is drawn from broker. So if a consumer dies
before a message is completely processed, the message will be processed
again. Is it possible?

Thanks.

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message