Thanks for the info Jun.
Each broker (that host topic) has the latest (end) offset for each topic
and partition ? If yes, I was planning to use this rate-of-change vs
incoming injection rate of producer (only calculated for the attached
producer broker) to make decision to which partition would
Bhavesh,
I am not sure if load balancing based on the consumption rate (1.b) makes
sense. Each consumer typically consumes all partitions from a topic. So, as
long as the data in each partition is balanced, the consumption rate will
be balanced too. Selecting a partition based on the size of each
Hi Kafka Dev Team,
I would appreciate your feedback on moving producer partition selection
from producer to Broker. Also, please do let me know what is correct
process of collecting feedback from Kafka Dev team and/or community.
Thanks,
Bhavesh
On Tue, May 26, 2015 at 11:54 AM, Bhavesh Mistry
Hi Kafka Dev Team,
I am sorry I am new to process of discussion and/or KIP. So, I had
commented other email voting chain. Please do let me know correct process
for collecting and staring discussion with Kafka Dev Group.
Here is original message:
I have had experience with both producer and co