log.warn(STR0,topic,subscriptionName,consumer,subscribeRateLimiter.getSubscribeRate(),subscribeRateLimiter.getAvailableSubscribeRateLimit(consumer)); | log.warn(STR0,topic,subscriptionName,consumer,subscribeRateLimiter.get().getSubscribeRate(),subscribeRateLimiter.get().getAvailableSubscribeRateLimit(consumer)); | log.warn(STR0,topic,subscriptionName,consumer,subscribeRateLimiter.getSubscribeRate(),subscribeRateLimiter.getAvailableSubscribeRateLimit(consumer)) | log.warn(STR0,topic,subscriptionName,consumer,subscribeRateLimiter.get().getSubscribeRate(),subscribeRateLimiter.get().getAvailableSubscribeRateLimit(consumer)) | pulsar | 2cca8ce83667fccde428db536a1446eef2203f8e | org.apache.pulsar.broker.service.persistent.PersistentTopic | | _1 | subscribeRateLimiter |
---|
_2 | subscribeRateLimiter |
---|
| TCIVar | subscribeRateLimiter |
---|
v1 | log |
---|
v2 | STR0 |
---|
v3 | topic |
---|
v4 | subscriptionName |
---|
v5 | consumer |
---|
| | TCIVar | subscribeRateLimiter |
---|
v1 | log |
---|
v2 | STR0 |
---|
v3 | topic |
---|
v4 | subscriptionName |
---|
v5 | consumer |
---|
| Uses | True |