dfarr opened a new issue, #901:
URL: https://github.com/apache/pulsar-client-go/issues/901

   **Describe the solution you'd like**
   It would be awesome if the go client supported the consumer event listener, 
similar to the [java 
client](https://pulsar.apache.org/api/client/2.10.x/org/apache/pulsar/client/api/ConsumerEventListener.html).
   
   **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**
   - [slack 
thread](https://apache-pulsar.slack.com/archives/C5Z4T36F7/p1669690833804909)
   - [related stackoverflow 
question](https://stackoverflow.com/questions/74620723/group-messages-by-key-for-pulsar-key-shared-subscription-type)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to