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

Update resolve offset function to handle :offset_out_of_range errors #72

Merged
merged 1 commit into from
Jan 4, 2022
Merged

Update resolve offset function to handle :offset_out_of_range errors #72

merged 1 commit into from
Jan 4, 2022

Conversation

jamespeterschinner
Copy link
Contributor

@jamespeterschinner jamespeterschinner commented Jan 4, 2022

Fix for issue #71 resolve offset policy not being applied for offsets out of range.

The implementation is an update to the resolve_offset function, where by upon new assignments from the brod_group_coordinator the provided offset is checked to ensure it is within the range of :earliest -> :latest (inclusive) and if not picks the offset as set in the offset_reset_policy configuration option

@jamespeterschinner jamespeterschinner changed the title Add additional logic to resolve offset function for the offset reset … Update resolve offset function to handle :offset_out_of_range errors Jan 4, 2022
@josevalim josevalim merged commit 4388117 into dashbitco:main Jan 4, 2022
@josevalim
Copy link
Member

💚 💙 💜 💛 ❤️

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.

2 participants