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
