[GitHub] [pulsar] labuladong commented on issue #19210: [Bug] BacklogQuota not being enforced when it should be

["labuladong (via GitHub)" <gi...@apache.org>]

labuladong commented on issue #19210:
URL: https://github.com/apache/pulsar/issues/19210#issuecomment-1407329435

   Hi @zbentley @awitghirmai
   
   > I expected to see that after setting the Backlog Quota to 1 minute, and submitting messages contained in the backlog, that past the 1 minute mark, I should be getting a ProducerBlockedQuotaExceededException
   
   I guess you misunderstand the `producer_exception` type. Let me try to clarify. 
   
   The backlog check is a period task. And if the broker found the time backlog was exceeded, `producer_exception` will disconnect all connected producers in this topic:
   
   https://github.com/apache/pulsar/blob/c875365c648584910b1b2de4cf8492121f4e0c4e/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java#L86-L111
   
   It doesn't mean all the new producers cannot send messages on this topic. It only throws Exceptions to **existed** producers.
   
   I guess you created many new producers to test this function, so these producers all worked fine.


-- 
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