Skip to content

[improve][pip] PIP-313 Support force unsubscribe using consumer api#21452

Merged
Technoboy- merged 3 commits into
apache:masterfrom
rdhabalia:pip_unsub
Dec 15, 2023
Merged

[improve][pip] PIP-313 Support force unsubscribe using consumer api#21452
Technoboy- merged 3 commits into
apache:masterfrom
rdhabalia:pip_unsub

Conversation

@rdhabalia

@rdhabalia rdhabalia commented Oct 27, 2023

Copy link
Copy Markdown
Contributor

Fixes #21451

Motivation

Modifications

Verifying this change

  • Make sure that the change passes the CI checks.

(Please pick either of the following options)

This change is a trivial rework / code cleanup without any test coverage.

(or)

This change is already covered by existing tests, such as (please describe tests).

(or)

This change added tests and can be verified as follows:

(example:)

  • Added integration tests for end-to-end deployment with large payloads (10MB)
  • Extended integration test for recovery after broker failure

Does this pull request potentially affect one of the following parts:

If the box was checked, please highlight the changes

  • Dependencies (add or upgrade a dependency)
  • The public API
  • The schema
  • The default values of configurations
  • The threading model
  • The binary protocol
  • The REST endpoints
  • The admin CLI options
  • The metrics
  • Anything that affects deployment

Documentation

  • doc
  • doc-required
  • doc-not-needed
  • doc-complete

Matching PR in forked repository

PR in forked repository:

@rdhabalia rdhabalia self-assigned this Oct 27, 2023
@github-actions github-actions Bot added the doc-not-needed Your PR changes do not impact docs label Oct 27, 2023
@liudezhi2098

Copy link
Copy Markdown
Contributor

Whether it would be more appropriate to add automatic cleaning subscribers, similar to automatically deleting inactive topics?

@rdhabalia

Copy link
Copy Markdown
Contributor Author

Whether it would be more appropriate to add automatic cleaning subscribers, similar to automatically deleting inactive topics?

Inactive topic doesn't have any sub but here in this case, when pulsar spout tries to unsubscribe on a shared sub, unsubscribe request fails first and it will also not close the consumer. so, in this case, both sub and consumer are still live and we should not perform any auto cleanup on such uncertain state.

Comment thread pip/pip_313.md
@@ -0,0 +1,74 @@
# PIP-313: Support force unsubscribe using consumer api

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

filename should be pip-313.md

@Technoboy- Technoboy- left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

Please update the vote thread link

@Technoboy- Technoboy- added this to the 3.2.0 milestone Dec 11, 2023
@Technoboy- Technoboy- merged commit c34a5d8 into apache:master Dec 15, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

doc-not-needed Your PR changes do not impact docs type/PIP

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Pulsar spout fails to unsubscribe and close consumers on a shared subscription

5 participants