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

Support consumer event listener #901

Closed
dfarr opened this issue Dec 5, 2022 · 1 comment · Fixed by #904
Closed

Support consumer event listener #901

dfarr opened this issue Dec 5, 2022 · 1 comment · Fixed by #904
Assignees

Comments

@dfarr
Copy link

dfarr commented Dec 5, 2022

Describe the solution you'd like
It would be awesome if the go client supported the consumer event listener, similar to the java client.

Is your feature request related to a problem? Please describe.
We have an application that uses a partitioned topic. On application scale out, we need to know which consumers have been unassigned from a topic/partition in order to clear the internal memory of our application for this partition.

Describe alternatives you've considered
We have explored a Key_Shared subscription type with a non-partitioned topic. When a scale out of the application occurs with this type of subscription unacked messages are not automatically re-delivered and message consumption is paused until the pending messages are acked/nacked. See apache/pulsar#15705. This behaviour prevents our application from using a Key_Shared subscription type.

Additional context

@labuladong
Copy link
Contributor

Assign to me @codelipenghui

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 a pull request may close this issue.

2 participants