有点像RocketMQ的顺序消费，只不过RocketMQ会有rebalance过程，这个直接内部线程消费的感觉