@Component
@RocketMQMessageListener(topic = "order-topic",consumerGroup = "order-group-consume",nameServer = "localhost:9876")
報錯
2020-12-15 13:44:20.190 ERROR 13656 --- [ main] c.a.c.s.b.r.i.RocketMQMessageSource : DefaultMQPullConsumer startup error: the specified group is blank
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
org.apache.rocketmq.client.exception.MQClientException: the specified group is blank
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
at org.apache.rocketmq.client.Validators.checkGroup(Validators.java:54) ~[rocketmq-client-4.5.1.jar:4.5.1]
at org.apache.rocketmq.client.impl.consumer.DefaultMQPullConsumerImpl.checkConfig(DefaultMQPullConsumerImpl.java:690) ~[rocketmq-client-4.5.1.jar:4.5.1]
at org.apache.rocketmq.client.impl.consumer.DefaultMQPullConsumerImpl.start(DefaultMQPullConsumerImpl.java:624) ~[rocketmq-client-4.5.1.jar:4.5.1]
at org.apache.rocketmq.client.consumer.DefaultMQPullConsumer.start(DefaultMQPullConsumer.java:292) ~[rocketmq-client-4.5.1.jar:4.5.1]
at com.alibaba.cloud.stream.binder.rocketmq.integration.RocketMQMessageSource.start(RocketMQMessageSource.java:145) ~[spring-cloud-starter-stream-rocketmq-2.2.1.RELEASE.jar:2.2.1.RELEASE]
at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.bindPollableConsumer(AbstractMessageChannelBinder.java:503) [spring-cloud-stream-3.0.3.RELEASE.jar:3.0.3.RELEASE]
at org.springframework.cloud.stream.binding.BindingService.doBindPollableConsumer(BindingService.java:217) [spring-cloud-stream-3.0.3.RELEASE.jar:3.0.3.RELEASE]
at org.springframework.cloud.stream.binding.BindingService.bindConsumer(BindingService.java:124) [spring-cloud-stream-3.0.3.RELEASE.jar:3.0.3.RELEASE]
at org.springframework.cloud.stream.binding.AbstractBindableProxyFactory.createAndBindInputs(AbstractBindableProxyFactory.java:112) [spring-cloud-stream-3.0.3.RELEASE.jar:3.0.3.RELEASE]
at org.springframework.cloud.stream.binding.InputBindingLifecycle.doStartWithBindable(InputBindingLifecycle.java:58) [spring-cloud-stream-3.0.3.RELEASE.jar:3.0.3.RELEASE]
at java.util.LinkedHashMap$LinkedValues.forEach(LinkedHashMap.java:608) ~[na:1.8.0_271]
at org.springframework.cloud.stream.binding.AbstractBindingLifecycle.start(AbstractBindingLifecycle.java:57) ~[spring-cloud-stream-3.0.3.RELEASE.jar:3.0.3.RELEASE]
at org.springframework.cloud.stream.binding.InputBindingLifecycle.start(InputBindingLifecycle.java:34) [spring-cloud-stream-3.0.3.RELEASE.jar:3.0.3.RELEASE]
at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:182) ~[spring-context-5.2.2.RELEASE.jar:5.2.2.RELEASE]
at org.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:53) ~[spring-context-5.2.2.RELEASE.jar:5.2.2.RELEASE]
at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:360) ~[spring-context-5.2.2.RELEASE.jar:5.2.2.RELEASE]
at org.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:158) ~[spring-context-5.2.2.RELEASE.jar:5.2.2.RELEASE]
at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:122) ~[spring-context-5.2.2.RELEASE.jar:5.2.2.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:894) ~[spring-context-5.2.2.RELEASE.jar:5.2.2.RELEASE]
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.finishRefresh(ServletWebServerApplicationContext.java:162) ~[spring-boot-2.2.2.RELEASE.jar:2.2.2.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:553) ~[spring-context-5.2.2.RELEASE.jar:5.2.2.RELEASE]
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:141) ~[spring-boot-2.2.2.RELEASE.jar:2.2.2.RELEASE]
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:747) ~[spring-boot-2.2.2.RELEASE.jar:2.2.2.RELEASE]
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397) ~[spring-boot-2.2.2.RELEASE.jar:2.2.2.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:315) ~[spring-boot-2.2.2.RELEASE.jar:2.2.2.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226) ~[spring-boot-2.2.2.RELEASE.jar:2.2.2.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1215) ~[spring-boot-2.2.2.RELEASE.jar:2.2.2.RELEASE]
at com.naocs.roketmq.RocketApplication.main(RocketApplication.java:13) ~[classes/:na]
uj5u.com熱心網友回復：
https://www.pianshen.com/article/93401661058/uj5u.com熱心網友回復：
您可以看完一樓嗎？
uj5u.com熱心網友回復：
你可以把代碼貼全一點，而且報錯資訊說了你的組為空，你可以仔細看一下是否能監聽到你的生產者
uj5u.com熱心網友回復：
這就是所有的，下面就單純實作,return null，沒做任何處理
uj5u.com熱心網友回復：
FSG Typ:PW 70 d/A/IP 40 1708Z03-065.011/01SOLORTRON DP2P 415BC33P40 971415-1探頭
FLEXIM FLUXUS F608手流量計SOLARTRON 971415-1
SELCO T2900.0010 AC400V 5A差動保護器
HAWS 8317CTFP 240V/60HZ 304STEEL
ESA GENIO A-001-05-C-N-230-T
BONFIGLIOLI Trasmital
TYPE 7C183KDA87Q4UCLA CODE 2T718C3K087001
BONFIGLIOLI 7C183KDA87Q4UCLA電機
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/235060.html
標籤：Java EE
上一篇：新手問題？幫忙解答疑惑一下 謝謝