You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by "heesung-sn (via GitHub)" <gi...@apache.org> on 2023/01/28 21:33:34 UTC

[GitHub] [pulsar] heesung-sn commented on pull request #19343: [improve][pulsar] Removed checkBackloggedCursors() from subscribe

heesung-sn commented on PR #19343:
URL: https://github.com/apache/pulsar/pull/19343#issuecomment-1407492806

   Also,
   
   If we still want to call this operation, checkBackloggedCursors asynchronously but more frequently, we could run such async operations in a separate thread and run it more frequently, every x milliseconds(out side of updateStats), if there are any requests (with deduplication).
   
   // Example 
   '''
   AsyncOpManager:
   
   var dedupedOps<Op>
   
   void schedule(Op op) // dedup/add op to dedupedOps.
   
   void start(){
   
    while(true)
     // wakeup every x milliseconds s(configurable) and run the deduped ops
   
   }
   '''
   


-- 
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-unsubscribe@pulsar.apache.org

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