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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
