rdhabalia opened a new pull request #11754:
URL: https://github.com/apache/pulsar/pull/11754


   ### Motivation
   
   Partitioned-topic Consumer doesn't cleanup the resources when it fails to 
create consumer, and it creates memory leak if consumer creation is keep 
failing with non-recoverable error (eg: `BusySubscriptionError`) which makes 
application unstable. One of the issue is `unAckedMessageTracker` timer, which 
still keeps consumer reference even after closing the timer-task in cleanup 
method and consume-creation failure introduces memory leak with objects 
associated with timer-task.
   
   
![image](https://user-images.githubusercontent.com/2898254/130532756-90850175-c59f-4f2e-a220-df2d0bc363af.png)
   
   
   ### Modification
   Close and clean timer task references.


-- 
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: commits-unsubscr...@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to