Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Default librdkafka message partitioner doesn't balance messages across partitions #2

Open
dcode opened this issue Dec 2, 2017 · 1 comment

Comments

@dcode
Copy link

dcode commented Dec 2, 2017

When you accept the default partitioning scheme in librdkafka, it will randomly choose a partition at startup and fill only that one. Ideally, we can evenly distribute bro events across multiple partitions. This will allow for much better scaling.

It's possible that I'm overlooking something with the newer code in librdkafka. I've written some code to do this before, so I'll likely be sending you another PR if you don't fix it first.

@JonZeolla
Copy link
Owner

Good catch - would you mind opening a JIRA for this? There are definitely some performance improvements that can be made to the package, and we could use some more thoroughly reviewed documentation, both of which I hope to address in early 2018. That said, any contributions are very welcome!

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants