Yes, I'm pretty sure keys are now retained with the message and returned
in the consumer.
In the Java/Scala client, ConsumerIterator returns a MessageAndMetadata
which includes key, message, topic, partition, and offset
-David
On 5/9/13 10:44 AM, Yu, Libo wrote:
Hi,
I am looking at the example producer code for kafka 0.8.
I notice it is possible to specify a key when creating
KeyedMessage. This key will be used for assigning the
message to some partition. I wonder if the key will be
received by the consumer. Thanks.
Libo
