-
Notifications
You must be signed in to change notification settings - Fork 3.6k
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
Send Key hash range change events to consumers in Key_Shared subscription. #6555
Comments
Please up. |
When adding this feature, would it be possible to support this in the asynchronous API of the Pulsar Java Client too? I guess race conditions could be problematic unless pending receives are completed with exceptions? |
@lhotari We have a consumer events listener https://github.com/apache/pulsar/blob/6704f12104219611164aa2bb5bbdfc929613f1bf/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerEventListener.java, users need to register a listener for getting the new events of the consumer pulsar/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java Line 410 in ef06691
|
…ey_Shared subscription. Hi @codelipenghui, can you please take a look?
…ey_Shared subscription.
…ey_Shared subscription.
…ey_Shared subscription.
…s in Key_Shared subscription.
…ey_Shared subscription.
…s in Key_Shared subscription.
…onsumers in Key_Shared subscription.
…onsumers in Key_Shared subscription.
…ey_Shared subscription.
…s in Key_Shared subscription.
…onsumers in Key_Shared subscription.
… events to consumers in Key_Shared subscription.
…ey_Shared subscription.
…s in Key_Shared subscription.
…onsumers in Key_Shared subscription.
… events to consumers in Key_Shared subscription.
…range change events to consumers in Key_Shared subscription.
@codelipenghui Can you share a bit about what the remain works are before we close this issue? |
I have shared an update about on-going design work which will be targeting this requirement, the updates are shared in this GitHub Discussion: #22912 (reply in thread) . |
Master issue: #4077
Is your feature request related to a problem? Please describe.
Send Key hash range change events to consumers in Key_Shared subscription.
The text was updated successfully, but these errors were encountered: