Kafka, mail # user - Re: Question about Partitions not receive equal number messages - 2013-04-17, 14:48
Solr & Elasticsearch trainings in New York & San Francisco [more info][hide]
 Search Hadoop and all its subprojects:

Switch to Plain View
+
Helin Xiang 2013-04-17, 10:00
+
Neha Narkhede 2013-04-17, 13:30
Copy link to this message
-
Re: Question about Partitions not receive equal number messages
Hi Neha,

We can not understand why the partitions will be unbalanced if each thread
gets different number of messages.

We go through the code of producer, and the partition number is generated
by "random.nextInt(numOfPartitions)", so we think even if different thread
gets different number of messages, theoretically, the partition number
shoule be evenly distributed.

Could you please give us more detailed explanation about this?

Thanks a lot.

Guodong
On Wed, Apr 17, 2013 at 9:29 PM, Neha Narkhede <[EMAIL PROTECTED]>wrote:
 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB