- 
                Notifications
    
You must be signed in to change notification settings  - Fork 935
 
Open
Description
由于consumeThreadMin和consumeThreadMax在5.x版本当中被弃用,我有几个问题
- 由于线程数量无法再设置核心线程数以及最大线程数,线程数量只能设置为固定线程,假设我设置为固定20,如果我在多Topic的情况下,一旦项目启动并创建了消费者,那么创建的消费者线程数量就将会是 n(topic数量) * 20, 这样就会有大量的线程进入Waiting状态并浪费资源
 - 消费者线程数调低会导致业务高峰期消费不及时
 - 如果按照上述逻辑,并且合并Topic也会有问题,如果同一Topic内,多个业务逻辑比如A、B、C,其中A会产生大量消息,B、C很少,如果A产生了大量消息并导致堆积会造成B、C也造成堆积
 
所以结合上述的问题,为什么不设计成允许动态线程池,低峰期自动降低线程数,高峰期自动开辟线程到最大线程数,队列满之后的线程认为来不及处理不处理呢,虚心请教一下
Metadata
Metadata
Assignees
Labels
No labels