[GitHub] Cicizz opened a new issue #653: Consumer setPullInterval is not working when pullInterval > 120 seconds

[GitBox <gi...@apache.org>]

Cicizz opened a new issue #653: Consumer setPullInterval is not working when pullInterval > 120 seconds
URL: https://github.com/apache/rocketmq/issues/653
 
 
   ** BUG REPORT **
   
   1. Please describe the issue you observed:
     I use pushConsumer to consume messages,I need to consume slowly,so I check the code of consumer,and I find 2 methods to solve it,and one of them is 
     ` consumer.setPullInterval(10*60*1000); `,but I find when pullInterval is over 120 seconds,the consumer will continue pull messages from broker every 120 seconds.
   
   2. Please tell us about your environment:
     rocketmq3.2.6，4.3.0，4.3.1
   
   3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):
     I find this problem was caused by ` RebalanceImpl.updateProcessQueueTableInRebalance()`
   
     when rebalance happend，the process queue will check this queue whether  pull expired or not，and the default queue pull expire time is 120 seconds, if queue pull expired，then will remove this queue from this consumer and create a new process queue to consume this message queue,and create a pull request of this queue to pull messages from broker,so pullInterval is not working when pullInterval  > 120 seconds.I think when check the queue pullExpired ,should also check the pullInterval.
   
     maybe it is not a BUG,but is also  confused,

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services