Skip to content

Add on_shutdown with options abandon and release #197

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

Open
wants to merge 1 commit into
base: main
Choose a base branch
from

Conversation

yaauie
Copy link
Contributor

@yaauie yaauie commented Jun 26, 2025

In some configurations, it would be helpful for the input plugin's consumers to unsubscribe from their topics during shutdown, especially with sticky-type partition assignment strategies with non-static group membership.

This would allow the consumer's assigned partitions to be immediately eligible to be assigned to another member of the group, instead of needing to wait out broker-side timeouts.

This patch introduces a new option on_shutdown, with two options:

  • release: revoke all current subscriptions, releasing the assigned partitions so that they can be immediately assigned to another member of the group
  • abandon (backward-compatible default): leave the subscription in-tact when closing, allowing broker to begin reassigning these partitions in its own time

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.

1 participant