which version of storm-kafka, are you using? On Wed, May 11, 2016 at 12:29 AM, Milind Vaidya <kava...@gmail.com> wrote:
> Anybody ? Anything about this ? > > On Wed, May 4, 2016 at 11:31 AM, Milind Vaidya <kava...@gmail.com> wrote: > >> Is there any way I can know what Kafka offset corresponds to current >> tuple I am processing in a bolt ? >> >> Use case : Need to batch events from Kafka, persists them to a local file >> and eventually upload it to the S3. To manager failure cases, need to know >> the Kafka offset for a message, so that it can be persisted to Zookeeper >> and will be used to write / upload file. >> >> > -- Regards, Abhishek Agarwal