Skip to content

Fix for an infinite loop in cooperative sticky assignor#4800

Merged
Emanuele Sabellico (emasab) merged 1 commit intomasterfrom
dev_fix_cooperative_sticky_infinite_loop
Oct 16, 2024
Merged

Fix for an infinite loop in cooperative sticky assignor#4800
Emanuele Sabellico (emasab) merged 1 commit intomasterfrom
dev_fix_cooperative_sticky_infinite_loop

Conversation

@emasab
Copy link
Copy Markdown
Contributor

when potential topic partitions are less than number of members.

Closes #4783

@emasab Emanuele Sabellico (emasab) requested a review from a team as a code owner July 31, 2024 16:12
@mensfeld
Copy link
Copy Markdown

I can confirm this works :) I applied it via a patch in rdkafka-ruby and was not able to trigger it anymore. Thank you!

@emasab
Copy link
Copy Markdown
Contributor Author

Thank you Maciej Mensfeld (@mensfeld) ! Couldn't push it earlier because we're reviewing company flows after the incident that happened to public repositories earlier in the month.

@mensfeld
Copy link
Copy Markdown

No worries. You motivated me to finally craft ability to patch librdkafka for rdkafka-ruby so now I can also expose the needed fork-protect APIs for MacOS. Thank you for all your hard work 🙏

@confluent-cla-assistant
Copy link
Copy Markdown

🎉 All Contributor License Agreements have been signed. Ready to merge.
Please push an empty commit if you would like to re-run the checks to verify CLA status for all contributors.

Copy link
Copy Markdown
Member

@pranavrth Pranav Rathi (pranavrth) left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks. Please rebase and we should be good to merge.

@airlock-confluentinc airlock-confluentinc Bot force-pushed the dev_fix_cooperative_sticky_infinite_loop branch from e6c8a1f to 583dc56 Compare October 16, 2024 07:18
Copy link
Copy Markdown
Member

@pranavrth Pranav Rathi (pranavrth) left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM!. We can add a test but I don't feel there is necessity of a test for this kind of bug.

@mensfeld
Copy link
Copy Markdown

Pranav Rathi (@pranavrth) I've been running a similar patch for this for weeks, I have specs in rdkafka-ruby and karafka. This solves it as I was able to reproduce it on my side in 100%.

when potential topic partitions are less than currently
assigned ones.
@airlock-confluentinc airlock-confluentinc Bot force-pushed the dev_fix_cooperative_sticky_infinite_loop branch from 583dc56 to 993aa1e Compare October 16, 2024 08:24
@pranavrth
Copy link
Copy Markdown
Member

Maciej Mensfeld (@mensfeld) - I was saying that we don't need a test for this kind of trivial bug.

Copy link
Copy Markdown
Member

@pranavrth Pranav Rathi (pranavrth) left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM!.

@emasab Emanuele Sabellico (emasab) deleted the dev_fix_cooperative_sticky_infinite_loop branch October 16, 2024 08:46
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

Successfully merging this pull request may close these issues.

cooperative-sticky performReassignments can get stuck in an infinite loop

3 participants