配置namespace无效
まだ誰も着手していません。
評価
- 難易度
- 3/5
- 見積もり時間
- 1〜2日
- 初心者へのやさしさ
- 52/100
- issue の種類
- バグ
- 明瞭さ
- おおむね明確
- 活発さ
- 静か
- 技術スタック
- java, spring-boot
調査の方向性
RocketMQMessageListener の例と、示されている rocketmq-v5-client-spring-boot-starter 2.3.3 の設定で失敗を再現します。DefaultListenerContainer.start、ListenerContainerConfiguration.startContainer、PushConsumerBuilderImpl.build から調査を始め、アノテーションベースとプロパティベースの namespace 処理を比較します。namespace=uat で push consumer が正常に起動し、既存の namespace なしの動作も引き続き機能すれば完了です。
索引モデルが issue の本文から書いたものです。
説明
只要在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`
- 主要言語
- Java
- スター
- 2.3k
- フォーク
- 941
- PR マージ指標
- 30日以内にマージされた PR はありません
環境構築
- Dockerfile・Docker Compose ファイルなし
- プルリクエストのテンプレートあり
- コントリビューションガイドなし
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
apache/rocketmq-spring のほかの issue
-
[Bug] RocketMQClientTemplate.receiveAsync closes the shared SimpleConsumer, breaking all subsequent operations対応中かも @wang-jiahua が 57 日前に担当しました。 オープン
難易度 2/5 1〜3時間 初心者へのやさしさ 88/100
apache/rocketmq-spring#780 · コメント 3 件 ·
-
编译报错オープン
難易度 2/5 1〜3時間 初心者へのやさしさ 72/100
apache/rocketmq-spring#692 · コメント 1 件 ·
-
難易度 2/5 1〜3時間 初心者へのやさしさ 68/100
apache/rocketmq-spring#678 · コメント 2 件 ·
-
難易度 1/5 1時間未満 初心者へのやさしさ 82/100
apache/rocketmq-spring#670 · コメント 1 件 ·
-
難易度 2/5 1〜3時間 初心者へのやさしさ 62/100
apache/rocketmq-spring#609 · コメント 3 件 ·
apache/rocketmq-spring の issue をすべて見る
似ている issue
-
status: waiting-for-triage
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
spring-projects/spring-framework#37614 ·
メンテナーはふだん 1 日以内に返信
-
azure-spring azure-spring-aad Client
難易度 2/5 1〜3時間 初心者へのやさしさ 72/100
Azure/azure-sdk-for-java#51046 · リアクション 1 件 ·
メンテナーはふだん 1 日以内に返信
-
helm-knative-apply.sh fails with Helm 4対応中かも このイシューにリンクされたプルリクエストがオープン中、またはマージ済みです。 オープンarea: triage theme: undefined
難易度 2/5 1〜3時間 初心者へのやさしさ 85/100
jhipster/generator-jhipster#35895 ·
メンテナーはふだん 1 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
メンテナーはふだん 1 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 85/100
oracle/graalvm-reachability-metadata#11659 ·
メンテナーはふだん 1 日以内に返信