lionMonkey opened a new issue, #21198:
URL: https://github.com/apache/pulsar/issues/21198

   ### Search before asking
   
   - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) 
and found nothing similar.
   
   
   ### Version
   
   pulsarClient: 
     <dependency>
               <groupId>org.apache.pulsar</groupId>
               <artifactId>pulsar-client-all</artifactId>
               <version>2.10.2</version>
    </dependency>
   
   ### Minimal reproduce step
   
   I can see patternMultiTopicsConsumerImpl consumer named iot-store  by arthas
   [arthas@1]$ ognl -c 255316f2  -x 1 
"@com.*****.utils.SpringUtils@getBean('initConsumers').consumers"
   @ArrayList[
       @PatternMultiTopicsConsumerImpl[ConsumerBase{subscription='iot-store', 
consumerName='PulsarPropertyConsumerImplShared0', 
topic='MultiTopicsConsumer-6f265'}],
       @ConsumerImpl[ConsumerBase{subscription='iot-store', 
consumerName='ProductEventConsumerShared0', 
topic='persistent://t7011854583792645/iot_S1894cf4ecaf/v1-business-iot-product'}],
       @ConsumerImpl[ConsumerBase{subscription='iot-store', 
consumerName='DeviceEventConsumerShared0', 
topic='persistent://t7011854583792645/iot_S1894cf4ecaf/v1-business-iot-device'}],
       @PatternMultiTopicsConsumerImpl[ConsumerBase{subscription='iot-store', 
consumerName='PulsarEventConsumerImplShared0', 
topic='MultiTopicsConsumer-3869d'}],
       @PatternMultiTopicsConsumerImpl[ConsumerBase{subscription='iot-store', 
consumerName='PulsarServiceUpConsumerImplShared0', 
topic='MultiTopicsConsumer-f375b'}],
       @PatternMultiTopicsConsumerImpl[ConsumerBase{subscription='iot-store', 
consumerName='PulsarServiceDownConsumerImplShared0', 
topic='MultiTopicsConsumer-88e4c'}],
   ]
   
   
   But HashedWheelTimer wheel don't have it,Maybe this method is error to watch 
 timing work 。But PatternMultiTopicsConsumerImpl RecheckPatternTimeout timing 
work must not exec;
   
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   [arthas@1]$ ognl -c 255316f2 -x 4  
"@com.das.libcore.web.utils.SpringUtils@getBean('pulsarClient').timer.wheel" | 
grep  task=@PatternMultiTopicsConsumerImpl
   
   ### What did you expect to see?
   
   PatternMultiTopicsConsumerImpl recheckPatternTimeout can exec Regularly;
   
   ### What did you see instead?
   
   PatternMultiTopicsConsumerImpl recheckPatternTimeout can’t exec Regularly;
   
   ### Anything else?
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [ ] I'm willing to submit a PR!


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

Reply via email to