为什么要在5.x弃用consumeThreadMax
Nessuno ha ancora preso questa issue.
Valutazione
- Difficoltà
- 5/5
- Tempo stimato
- Più di una settimana
- Idoneità per principianti
- 30/100
- Tipo di issue
- Funzionalità
- Chiarezza
- Da chiarire
- Stato di attività
- Attiva
- Stack tecnologico
- java
- Ambito
- distributed-systems
Direzione di ricerca
La issue non indica file, test o punti di ingresso. Inizia tracciando la configurazione dei consumer thread di 5.x e la motivazione per la deprecazione di consumeThreadMax, quindi esamina i casi descritti relativi a più topic e a topic uniti. Per considerare il lavoro completato, sarebbero necessari un design concordato e una decisione dei maintainer sul comportamento dinamico del thread pool.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Descrizione
由于consumeThreadMin和consumeThreadMax在5.x版本当中被弃用，我有几个问题
- 由于线程数量无法再设置核心线程数以及最大线程数，线程数量只能设置为固定线程，假设我设置为固定20，如果我在多Topic的情况下，一旦项目启动并创建了消费者，那么创建的消费者线程数量就将会是 n(topic数量) * 20, 这样就会有大量的线程进入Waiting状态并浪费资源
- 消费者线程数调低会导致业务高峰期消费不及时
- 如果按照上述逻辑，并且合并Topic也会有问题，如果同一Topic内，多个业务逻辑比如A、B、C，其中A会产生大量消息，B、C很少，如果A产生了大量消息并导致堆积会造成B、C也造成堆积
所以结合上述的问题，为什么不设计成允许动态线程池，低峰期自动降低线程数，高峰期自动开辟线程到最大线程数，队列满之后的线程认为来不及处理不处理呢，虚心请教一下
- Lingua principale
- Java
- Stelle
- 2.3k
- Fork
- 941
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Preparare l'ambiente
- Nessun Dockerfile né file Docker Compose
- Ha un modello di pull request
- Nessuna guida per i contributori
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Altre issue di apache/rocketmq-spring
-
[Bug] RocketMQClientTemplate.receiveAsync closes the shared SimpleConsumer, breaking all subsequent operationsForse già presa @wang-jiahua l’ha presa 58 giorni fa. Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 88/100
apache/rocketmq-spring#780 · 3 commenti ·
-
编译报错Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 72/100
apache/rocketmq-spring#692 · 1 commento ·
-
消费者注册时候对nameserver取值有点问题Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 68/100
apache/rocketmq-spring#678 · 2 commenti ·
-
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 82/100
apache/rocketmq-spring#670 · 1 commento ·
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 62/100
apache/rocketmq-spring#609 · 3 commenti ·
Tutte le issue di apache/rocketmq-spring
Issue simili
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 82/100
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 88/100
quarkusio/quarkus-agent-mcp#302 ·
I maintainer di solito rispondono entro 2 giorni
-
build
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 85/100
MetricsHub/metricshub-community#1472 ·
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 82/100
I maintainer di solito rispondono entro 1 giorno
-
IdentityArrayObjectSet iterator remove may throw ArrayIndexOutOfBoundsExceptionForse già presa @jiteshkhatri11 l’ha presa oggi. Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 72/100
javapathfinder/jpf-core#660 · 1 commento ·