Currently, partition # is not exposed in MessageAndMetaData. We do plan to expose such information in a future release. How do you plan to use this info?
Thanks, Jun On Thu, Jun 27, 2013 at 7:13 AM, Hussain Pirosha < hussain.piro...@impetus.co.in> wrote: > After retrieving a kafka stream or kafka message how to get the > corresponding partition number to which it belongs ? I am using kafka > version 0.7.2. > More specifically kafka.consumer.KafkaStream and > kafka.message.MessageAndMetaData classes, does not provide API to retrieve > partition number. Are there any other API's to get the partition number ? > > Thanks, > Hussain > > > ________________________________ > > > > > > > NOTE: This message may contain information that is confidential, > proprietary, privileged or otherwise protected by law. The message is > intended solely for the named addressee. If received in error, please > destroy and notify the sender. Any use of this email is prohibited when > received in error. Impetus does not represent, warrant and/or guarantee, > that the integrity of this communication has been maintained nor that the > communication is free of errors, virus, interception or interference. >