首页 > 其他分享 >面试题：一个consumer订阅两个topic，其中一个topic消息过多堆积了，会影响另一个topic消费吗

面试题：一个consumer订阅两个topic，其中一个topic消息过多堆积了，会影响另一个topic消费吗

时间：2022-09-19 10:14:07浏览次数：69  
标签：queueId 面试题 TopicTest2 PullMessageService NettyClientPublicExecutor topic broker

 

问题：一个consumer订阅两个topic，其中一个topic消息过多堆积了，会影响另一个topic消费吗
答案：不影响。
为什么呢？

因为rocketmq首先对消息进行负载均衡（rebalance），就是将topic中的队列按照consumer进行分配之后，将pullRequest(里面存放了topic,brokerName,queueId)放入到一个linkedBlockingQueue中，这个时候已经排好了后面消费的顺序。例如100个request中有大概50个是TopicTest1,另外50个是TopicTest2。

在实际进行拉取的时候，多个线程从LinkedBlockingQueue中去take消息，按照放入的顺序进行消费，这个时候topicTest1消息已经堆积了，但还是会照常去消费TopicTest2，如果处理速度不影响的话，只有当TopicTest消费的速度过慢，导致将所有的线程都占住了，那也只是一时的，会影响TopicTest2的消费速度，但不会阻塞TopicTest2的消费。

如下图所示，PullMessageService线程负责将request放入队列，同时NettyClientPublicExecutor_1,2,3,4负责处理消息拉取，他们会并发从队列中获取消息，当获取到消息并处理完后会接着去take新的消息然后继续处理。

-------放入消息-----：MessageQueue [topic=%RETRY%testConsumer, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=1]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=1]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=%RETRY%testConsumer, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
拉取到消息：TopicTest1,NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
拉取到消息：TopicTest1,NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=%RETRY%testConsumer, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=1]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=%RETRY%testConsumer, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=1]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
拉取到消息：TopicTest1,NettyClientPublicExecutor_1
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=%RETRY%testConsumer, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=1]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=%RETRY%testConsumer, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=1]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=%RETRY%testConsumer, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
拉取到消息：TopicTest1,NettyClientPublicExecutor_2
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=0]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_4
处理TopicTest2...NettyClientPublicExecutor_4
-------放入消息-----：MessageQueue [topic=%RETRY%testConsumer, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=0]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=3]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_1
处理TopicTest2...NettyClientPublicExecutor_1
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=2]PullMessageService
-------放入消息-----：MessageQueue [topic=TopicTest2, brokerName=broker-a, queueId=1]PullMessageService
拉取到消息：TopicTest1,NettyClientPublicExecutor_3
-------放入消息-----：MessageQueue [topic=TopicTest1, brokerName=broker-a, queueId=2]PullMessageService
拉取到消息：TopicTest2,NettyClientPublicExecutor_2
处理TopicTest2...NettyClientPublicExecutor_2
拉取到消息：TopicTest2,NettyClientPublicExecutor_3
处理TopicTest2...NettyClientPublicExecutor_3

https://blog.csdn.net/b1303110335/article/details/118755341

 

标签：queueId,面试题,TopicTest2,PullMessageService,NettyClientPublicExecutor,topic,broker
From： https://www.cnblogs.com/softidea/p/16706760.html

相关文章

  • Js手写面试题第三天
    前言❓有任何疑问都可以私信我解答⚡仓库地址：​https://gitee.com/super_li_yu/jsexamdemo......
  • 崩溃！学了三年Python，这几道面试题还是答不好
    每天进步一点点，关注我们哦，每天分享测试技术文章本文章出自【码同学软件测试】码同学公众号：自动化软件测试，领取资料可加：magetest码同学抖音号：小码哥聊软件测试Python语......
  • 在consumer producer运行时停止kafka服务端会怎样
    结论服务端停止时，客户端程序会报错；服务端启动后，客户端程序能继续运行。也就是，消费者线程并未异常退出。实验步骤（1）停止后，consumer和producer会报错。消费者：.___......
  • 0-2 测试面试题- 测试方法_压力测试怎么测_设计朋友圈点赞_HTTP报文段_HTTP请求报文_T
    面试题及解析答案来自牛客网https://www.nowcoder.com/exam/interview/5了解什么测试方法？测试的方法？写测试用例的方法？分析测试点的方法？测试是个大工程，很多环节，具......
  • 数据类型扩展及面试题讲解
    数据类型扩展及面试题讲解importjava.math.BigDecimal;​publicclassdemo03{  publicstaticvoidmain(String[]args){    //整数拓展 进制二进......
  • 在producer/consumer运行时删除topic会怎么样
    broker端有个参数（kafka_2.13-3.2.1/config/server.properties），auto.create.topics.enable，默认为true。意思是，当生产者、消费者读写一个不存在的topic时，是否自动创建该topic......
  • redis面试题汇总
     1redis持久化机制 redis是一个支持持久化的内存数据库，通过持久化机制把内存中的数据同步到硬盘文件来保证数据持久化，当redis重启后通过把硬盘文件重新加载到内存，就能......
  • Hive重要知识点及面试题
    知识点：Hive是数据仓库建模工具之一。传统的关系数据库具有结构化程度高、独立性强、冗余度低，主要是操作型数据库和分析型数据库。其中操作型数据库：主要用于业务支撑。一......
  • 肖sir ___海康面试题
    1、一个框为必填项     不输入的时候 可以点击提交        是前端bug 还是后端bug   2、前端做了校验 ，怎么判断后端有没有做校验3、一个字段校验不能......
  • 【金九银十必问面试题】站在架构师角度分析问题，如何解决TCC中的悬挂问题
    “如何解决TCC中的悬挂问题”！一个工作了4年的Java程序员，去京东面试，被问到这个问题。大家好，我是Mic，一个工作了14年的Java程序员这个问题面试官想考察什么方面的知识？我们......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99