Re: partition key patch

2013-07-17 Thread Wang Guozhang
I will do it. On Wed, Jul 17, 2013 at 2:17 PM, Jay Kreps wrote: > Any one able to take a look at this? > > https://issues.apache.org/jira/browse/KAFKA-925 > > -Jay > -- -- Guozhang

Re: Helping out

2013-07-03 Thread Wang Guozhang
Yes. And as you can see in that function, when no key is specified, it chooses a partition for each message in a round-robin manner, while we want to make all the messages in the same batch with the same topic to be sent to one partition. So if the message is the first seen with the topic in the b