That was exactly what I was looking for.
Thanks
Arun
-Original Message-
From: tao xiao [mailto:xiaotao...@gmail.com]
Sent: Monday, February 16, 2015 12:20 PM
To: users@kafka.apache.org
Subject: Re: API to get the partition number
You can get the partition number and offset of the
You can get the partition number and offset of the message by
MessageAndMetadata.partition() and MessageAndMetadata.offset().
To your scenario you can turn off auto commit auto.commit.enable=false and
then commit by yourself after finishing message consumption.
On Mon, Feb 16, 2015 at 1:40 PM, Ar
Hi,
Is there a way to get the current partition number and current offset, when
using the *high level consumer* in 0.8.2?
I went through the previous messages and in the previous version I think there
are none.
The reason we want to do this, is that I plan to have a consumer without the
