Skip to content
This repository has been archived by the owner on May 13, 2019. It is now read-only.

Partitions are split evenly among consumers / some consumers left out #61

Closed
nemosupremo opened this issue Jul 5, 2015 · 2 comments
Closed

Partitions are split evenly among consumers / some consumers left out #61

nemosupremo opened this issue Jul 5, 2015 · 2 comments

Comments

@nemosupremo
Copy link
Contributor

Currently, the library attempts to split partitions among consumers in a completely even manner (each consumer gets the same number of partitions. For example, if you have 32 partitions and 9 consumers, 8 consumers get assigned partitions at 4 partitions ea., and one is just left hanging. Is that intentional - it seems like a pretty easy fix.
@nemosupremo nemosupremo mentioned this issue Jul 5, 2015
Closed
nemosupremo added a commit to ChannelMeter/kafka that referenced this issue Jul 5, 2015
@nemosupremo
Divide partitions amount all consumers. See wvanbergen#61
8928a13
nemosupremo added a commit to ChannelMeter/kafka that referenced this issue Jul 5, 2015
@nemosupremo
Divide partitions amount all consumers. See wvanbergen#61
abd1773
@wvanbergen
Copy link
Owner

That is not intentional, and should be relatively easy to fix.

I will be on vacation the next three weeks; so I am not sure if I will be able to look at this any time soon though.

@nemosupremo nemosupremo mentioned this issue Jul 6, 2015
Merged
nemosupremo added a commit to ChannelMeter/kafka that referenced this issue Aug 11, 2015
@nemosupremo
Test to ensure that partitions are divided optimally among consumers. w…
09e71bb 
…vanbergen#61 / wvanbergen#63
wvanbergen added a commit that referenced this issue Aug 11, 2015
@wvanbergen
Merge pull request #63 from ChannelMeter/divide-work-all
0a7abfc 
Divide partitions among all consumers. See #61
@nemosupremo
Copy link
Contributor Author

Fixed with #63

xq262144 pushed a commit to crask/kafka that referenced this issue Nov 24, 2015
@nemosupremo @xq262144
Divide partitions amount all consumers. See wvanbergen#61
696c1f2
xq262144 pushed a commit to crask/kafka that referenced this issue Nov 24, 2015
@nemosupremo @xq262144
Test to ensure that partitions are divided optimally among consumers. w…
13e223b 
…vanbergen#61 / wvanbergen#63
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@wvanbergen @nemosupremo