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.

Sign up for GitHub

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

Jump to bottom

"range" assignment updates #712

Merged

daniil-quix merged 2 commits into main from fix/assignment-updates

Jan 15, 2025

Collaborator

daniil-quix commented Jan 15, 2025

Enforce "range" assignor for internal Consumers.
For app.get_consumer(), it can be overridden by whatever is passed in consumer_extra_config to Application.
Don't commit the current checkpoint on partition assignment anymore.
It used to make sense with "cooperative-sticky", but with "range" all partitions are revoked first anyway, and there's nothing to commit.

daniil-quix added 2 commits

January 15, 2025 14:53


          Don't commit the checkpoint on assign

4bb7f40

With "range" assignor, it doesn't make sense.


          Enforce "range" assignor for internal consumers

2368d3c

gwaramadze approved these changes

View reviewed changes

daniil-quix merged commit 63272b9 into main

3 checks passed

daniil-quix deleted the fix/assignment-updates branch

January 15, 2025 14:22

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet