L-xiaohai commented on issue #7538: URL: https://github.com/apache/rocketmq/issues/7538#issuecomment-1813674205
stop comsume topic queue  2023-11-16 10:01:05.263 [RebalanceService] INFO RebalanceImpl - %RETRY%vip2_node_client_to_wechat_center Rebalance changed, also update version: 1700100065163, 1700100065263 2023-11-16 10:01:05.263 [NettyClientPublicExecutor_8] INFO ClientRemotingProcessor - receive broker's notification[192.168.206.222:10811], the consumer group: vip2_site_wechat_to_client_center changed, rebalance immediately 2023-11-16 10:01:05.264 [NettyClientPublicExecutor_4] INFO ClientRemotingProcessor - receive broker's notification[192.168.206.221:10811], the consumer group: vip2_site_wechat_to_client_center changed, rebalance immediately 2023-11-16 10:01:05.264 [NettyClientPublicExecutor_1] INFO ClientRemotingProcessor - receive broker's notification[192.168.206.222:10911], the consumer group: vip2_site_wechat_to_client_center changed, rebalance immediately 2023-11-16 10:01:05.265 [NettyClientPublicExecutor_6] INFO ClientRemotingProcessor - receive broker's notification[192.168.206.221:10911], the consumer group: vip2_site_wechat_to_client_center changed, rebalance immediately 2023-11-16 10:01:05.660 [PullMessageService] INFO DefaultMQPushConsumerImpl - the pull request[PullRequest [consumerGroup=vip2_node_client_to_wechat_center, messageQueue=MessageQueue [topic=%RETRY%vip2_node_client_to_wechat_center , brokerName=yjy-broker-n1, queueId=0], nextOffset=0]] is dropped. 2023-11-16 10:01:06.124 [NettyClientSelector_1] DEBUG RocketmqRemoting - Response[request code: 307, response code: 0, opaque: 876426720] is written to channel[id: 0x489bbabb, L:/192.168.206.150:60008 - R:/192.168.206.222:10811] 2023-11-16 10:01:06.326 [PullMessageService] ERROR PullMessageService - Pull Message Service Run Method exception java.util.NoSuchElementException: null at java.util.TreeMap.key(TreeMap.java:1327) at java.util.TreeMap.firstKey(TreeMap.java:290) at org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl.pullMessage(DefaultMQPushConsumerImpl.java:286) -- 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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
