-Re: How to get partition information from Kafka Stream?
Jun Rao 2013-06-27, 14:17
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
On Thu, Jun 27, 2013 at 7:13 AM, Hussain Pirosha <
[EMAIL PROTECTED]> 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 ?
> 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.