[apache/rocketmq]SpringBoot 整合RocketMQ和Dubbo以后启动报错

2023-12-19 928 views
5

报错内容: 2020-09-29 17:27:15.934 ERROR 7076 --- [enderExecutor_3] c.a.c.s.b.r.i.RocketMQMessageHandler : RocketMQ Message hasn't been sent. Caused by No route info of this topic, dubboProtocolConfigSupplier-out-0 See http://rocketmq.apache.org/docs/faq/ for further details.


<dependency>
<groupid>com.alibaba.cloud</groupid>
<artifactid>spring-cloud-starter-dubbo</artifactid>
</dependency>
 <dependency>
        <groupid>com.alibaba.cloud</groupid>
        <artifactid>spring-cloud-starter-stream-rocketmq</artifactid>
        <exclusions>
            <exclusion>
                <groupid>org.apache.rocketmq</groupid>
                <artifactid>rocketmq-spring-boot</artifactid>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupid>org.apache.rocketmq</groupid>
        <artifactid>rocketmq-spring-boot</artifactid>
        <version>2.0.3</version>
    </dependency>

回答

5

你好,我也碰到这个问题,请问你后来是如何解决的?

9
    • 是的,刚遇到
8

没有创建对应的topic,而且没有打开自动创建,在broker.conf 中,设置autoCreateTopicEnable=true,生产环节建议关闭,手工创建

0

我知道是没有topic 主要是不知道为啥整合dubbo后就有依赖这个topic dubbo依赖里面也没有rocketmq啊

4

你解决没有啊,我也遇到了

5

I used "Aliyun Java Initializr " to create a new project, with spring-boot-dependencies.version=2.3.7.RELEASE, spring-cloud-alibaba-dependencies.version=2.2.2.RELEASE, rocketmq-spring-boot-starter.version=2.0.2 dubbo-spring-boot-starter.version=2.7.8 then with start error: [2022-03-03T19:54:41.258+0800] [INFO] [PostProcessorRegistrationDelegate.java:335] [main] [[Bean 'dubboProtocolConfigSupplier' of type [com.alibaba.cloud.dubbo.metadata.DubboProtocolConfigSupplier] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)]] [2022-03-03T19:54:49.968+0800] [INFO] [BeanFactoryAwareFunctionRegistry.java:276] [main] [[Looking up function 'dubboProtocolConfigSupplier' with acceptedOutputTypes: []]] [2022-03-03T19:54:50.247+0800] [INFO] [ExecutorConfigurationSupport.java:181] [main] [[Initializing ExecutorService 'taskScheduler']] [2022-03-03T19:54:50.353+0800] [INFO] [BeanFactoryAwareFunctionRegistry.java:276] [main] [[Looking up function 'dubboProtocolConfigSupplier' with acceptedOutputTypes: []]] [2022-03-03T19:54:50.372+0800] [INFO] [BeanFactoryAwareFunctionRegistry.java:276] [main] [[Looking up function 'dubboProtocolConfigSupplier' with acceptedOutputTypes: []]] [2022-03-03T19:54:50.373+0800] [INFO] [BeanFactoryAwareFunctionRegistry.java:276] [main] [[Looking up function 'dubboProtocolConfigSupplier' with acceptedOutputTypes: [application/json]]] [2022-03-03T19:54:54.170+0800] [INFO] [EventDrivenConsumer.java:107] [main] [[Adding {router} as a subscriber to the 'dubboProtocolConfigSupplier_integrationflow.channel#0' channel]] [2022-03-03T19:54:54.171+0800] [INFO] [AbstractSubscribableChannel.java:64] [main] [[Channel 'initializr-1.dubboProtocolConfigSupplier_integrationflow.channel#0' has 1 subscriber(s).]] [2022-03-03T19:54:54.171+0800] [INFO] [AbstractEndpoint.java:163] [main] [[started bean 'dubboProtocolConfigSupplier_integrationflow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0']] [2022-03-03T19:54:54.564+0800] [INFO] [CacheData.java:93] [main] [[[fixed-10.80.84.160_8849-77adf2a9-5284-4c37-951d-b61219497644] [add-listener] ok, tenant=77adf2a9-5284-4c37-951d-b61219497644, dataId=initializr.properties, group=DEFAULT_GROUP, cnt=1]] [2022-03-03T19:54:54.820+0800] [INFO] [AbstractSubscribableChannel.java:64] [main] [[Channel 'initializr-1.dubboProtocolConfigSupplier-out-0' has 1 subscriber(s).]] [2022-03-03T19:54:54.828+0800] [INFO] [AbstractEndpoint.java:163] [main] [[started bean 'dubboProtocolConfigSupplier_integrationflow.org.springframework.integration.config.SourcePollingChannelAdapterFactoryBean#0']] [2022-03-03T19:54:54.943+0800] [ERROR] [RocketMQMessageHandler.java:220] [AsyncSenderExecutor_1] [[RocketMQ Message hasn't been sent. Caused by No route info of this topic, dubboProtocolConfigSupplier-out-0 See http://rocketmq.apache.org/docs/faq/ for further details.]]

确认是引入 spring-cloud-starter-stream-rocketmq 的问题