配置namespace无效
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 3/5
- Tiempo estimado
- 1-2 días
- Aptitud para principiantes
- 52/100
- Tipo de issue
- Error
- Claridad
- Bastante claro
- Estado de actividad
- Tranquilo
- Stack tecnológico
- java, spring-boot
- Área
- backend, distributed-systems
Línea de trabajo
Reproduce el fallo con el ejemplo de RocketMQMessageListener y la configuración mostrada de rocketmq-v5-client-spring-boot-starter 2.3.3. Empieza por DefaultListenerContainer.start, ListenerContainerConfiguration.startContainer y PushConsumerBuilderImpl.build; después, compara el manejo del namespace basado en anotaciones y propiedades. La tarea estará completada cuando un consumidor push se inicie correctamente con namespace=uat y el comportamiento existente sin namespace siga funcionando.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
只要在RocketMQMessageListener里面配置namespace启动时就出现异常，不配置没问题
@Component @AllArgsConstructor @RocketMQMessageListener( consumerGroup = RocketMQConstants.ConsumerGroup.MERCHANT, topic = RocketMQConstants.Topic.TOPIC_TEST_ROCKETMQ ,namespace = "uat" ) public class TestMQListener implements RocketMQListener
pom依赖：
<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-v5-client-spring-boot-starter</artifactId> <version>2.3.3</version> </dependency>
配置项如下：
rocketmq: producer: topic: TP_DEFAULT_BUSINESS endpoints: xxx namespace: uat push-consumer: endpoints: xxx tag: '*' topic: TP_DEFAULT_BUSINESS namespace: uat
异常：
`Started container failed. DefaultListenerContainer{name='org.apache.rocketmq.client.support.DefaultListenerContainer_2', running=false, accessKey='', secretKey='', endpoints='', consumerGroup='CG_MERCHANT', tag='*', topic='TP_TEST_ROCKETMQ', type='tag', filterExpressionType=null, requestTimeout=PT3S, maxCachedMessageCount=1024, maxCacheMessageSizeInBytes=67108864, consumptionThreadCount=20, namespace='uat'}
java.lang.IllegalStateException: Failed to start RocketMQ push consumer
at org.apache.rocketmq.client.support.DefaultListenerContainer.start(DefaultListenerContainer.java:332) ~[rocketmq-v5-client-spring-boot-2.3.3.jar:2.3.3]
at org.apache.rocketmq.client.autoconfigure.ListenerContainerConfiguration.startContainer(ListenerContainerConfiguration.java:85) ~[rocketmq-v5-client-spring-boot-2.3.3.jar:2.3.3]
at org.apache.rocketmq.client.annotation.RocketMQMessageListenerBeanPostProcessor.start(RocketMQMessageListenerBeanPostProcessor.java:73) ~[rocketmq-v5-client-spring-boot-2.3.3.jar:2.3.3]
at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:285) ~[spring-context-6.1.15.jar:6.1.15]
at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:472) ~[spring-context-6.1.15.jar:6.1.15]
at java.base/java.lang.Iterable.forEach(Iterable.java:75) ~[na:na]
at org.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:257) ~[spring-context-6.1.15.jar:6.1.15]
at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:202) ~[spring-context-6.1.15.jar:6.1.15]
at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:990) ~[spring-context-6.1.15.jar:6.1.15]
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:628) ~[spring-context-6.1.15.jar:6.1.15]
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:146) ~[spring-boot-3.3.6.jar:3.3.6]
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:754) ~[spring-boot-3.3.6.jar:3.3.6]
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:456) ~[spring-boot-3.3.6.jar:3.3.6]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:335) ~[spring-boot-3.3.6.jar:3.3.6]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1363) ~[spring-boot-3.3.6.jar:3.3.6]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1352) ~[spring-boot-3.3.6.jar:3.3.6]
at com.yts.yyt.merchant.YytMerchantApplication.main(YytMerchantApplication.java:32) ~[classes/:na]
Caused by: java.lang.IllegalStateException: Expected the service PushConsumerImpl-1 [FAILED] to be RUNNING, but the service has FAILED
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractService.checkCurrentState(AbstractService.java:381) ~[rocketmq-client-java-5.0.7.jar:na]
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractService.awaitRunning(AbstractService.java:305) ~[rocketmq-client-java-5.0.7.jar:na]
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractIdleService.awaitRunning(AbstractIdleService.java:165) ~[rocketmq-client-java-5.0.7.jar:na]
at org.apache.rocketmq.client.java.impl.consumer.PushConsumerBuilderImpl.build(PushConsumerBuilderImpl.java:128) ~[rocketmq-client-java-5.0.7.jar:na]
at org.apache.rocketmq.client.support.DefaultListenerContainer.start(DefaultListenerContainer.java:330) ~[rocketmq-v5-client-spring-boot-2.3.3.jar:2.3.3]
... 16 common frames omitted`
- 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 56 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 78/100
aws/context-ontology-accelerator#325 ·
Los mantenedores suelen responder en 1 día
-
The README tells to run `mvn jeo:disassemble`, which fails with `No plugin found for prefix 'jeo'`Abierto
Dificultad 1/5 Menos de una hora Aptitud para principiantes 82/100
objectionary/jeo-maven-plugin#1938 ·
Los mantenedores suelen responder en 2 días
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
oVirt/ovirt-engine#1219 ·
Los mantenedores suelen responder en 1 día
-
pending:code-area pending:issue-category to-triage
Dificultad 2/5 1-3 horas Aptitud para principiantes 76/100
Los mantenedores suelen responder en 1 día
-
area:core bug priority:p2
Dificultad 2/5 1-3 horas Aptitud para principiantes 82/100
aomarai/minecraft-mcp#247 ·
Los mantenedores suelen responder en 1 día