为什么要在5.x弃用consumeThreadMax
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 5/5
- Tiempo estimado
- Más de una semana
- Aptitud para principiantes
- 30/100
- Tipo de issue
- Nueva funcionalidad
- Claridad
- Necesita aclaración
- Estado de actividad
- Activo
- Stack tecnológico
- java
- Área
- distributed-systems
Línea de trabajo
El issue no menciona archivos, pruebas ni puntos de entrada. Empieza rastreando la configuración de los hilos de consumidor de 5.x y la justificación para desaprobar consumeThreadMax; después, examina los casos de múltiples topics y topics fusionados que se describen. Para darlo por terminado, sería necesario contar con un diseño acordado y una decisión de los maintainers sobre el comportamiento dinámico del grupo de hilos.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
由于consumeThreadMin和consumeThreadMax在5.x版本当中被弃用，我有几个问题
- 由于线程数量无法再设置核心线程数以及最大线程数，线程数量只能设置为固定线程，假设我设置为固定20，如果我在多Topic的情况下，一旦项目启动并创建了消费者，那么创建的消费者线程数量就将会是 n(topic数量) * 20, 这样就会有大量的线程进入Waiting状态并浪费资源
- 消费者线程数调低会导致业务高峰期消费不及时
- 如果按照上述逻辑，并且合并Topic也会有问题，如果同一Topic内，多个业务逻辑比如A、B、C，其中A会产生大量消息，B、C很少，如果A产生了大量消息并导致堆积会造成B、C也造成堆积
所以结合上述的问题，为什么不设计成允许动态线程池，低峰期自动降低线程数，高峰期自动开辟线程到最大线程数，队列满之后的线程认为来不及处理不处理呢，虚心请教一下
- Lenguaje dominante
- Java
- Estrellas
- 2.3k
- Forks
- 941
- Métricas de merge de PR
- Sin PR fusionados en 30 d
Preparar el entorno
- Sin Dockerfile ni archivo de Docker Compose
- Tiene una plantilla de pull request
- Sin guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de apache/rocketmq-spring
-
[Bug] RocketMQClientTemplate.receiveAsync closes the shared SimpleConsumer, breaking all subsequent operationsPosiblemente ocupada @wang-jiahua la tomó hace 57 días. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 88/100
apache/rocketmq-spring#780 · 3 comentarios ·
-
编译报错Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
apache/rocketmq-spring#692 · 1 comentario ·
-
消费者注册时候对nameserver取值有点问题Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100
apache/rocketmq-spring#678 · 2 comentarios ·
-
Dificultad 1/5 Menos de una hora Aptitud para principiantes 82/100
apache/rocketmq-spring#670 · 1 comentario ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 62/100
apache/rocketmq-spring#609 · 3 comentarios ·
Todos los issues de apache/rocketmq-spring
Issues similares
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
-
bug/错误
Dificultad 2/5 1-3 horas Aptitud para principiantes 64/100
FCL-Team/FoldCraftLauncher#1982 · 2 comentarios ·
Los mantenedores suelen responder en 1 día
-
[BUG] micronaut-serde-oracle-jdbc-json brings a second OJDBC driver onto the runtime classpathPosiblemente ocupada @ZARAYACH la tomó hoy. Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
micronaut-projects/micronaut-serialization#1494 · 4 comentarios ·
Los mantenedores suelen responder en 2 días
-
Dificultad 1/5 1-3 horas Aptitud para principiantes 75/100
-
bug
Dificultad 2/5 1-3 horas Aptitud para principiantes 73/100
Los mantenedores suelen responder en 2 días