情況說明 在SpringBoot中集成了RocketMQ,實踐過程中,通過RocketMQ DashBoard觀察,生產者可以正常將進行消息提交;通過日誌及DashBoard觀察,消費者成功在RocketMQ中進行了註冊和訂閱且觀察到了消費者啟動的日誌行。問題是消費者依舊不會自動消費生產者提交的消息 ...
情況說明
在SpringBoot中集成了RocketMQ,實踐過程中,通過RocketMQ DashBoard觀察,生產者可以正常將進行消息提交;通過日誌及DashBoard觀察,消費者成功在RocketMQ中進行了註冊和訂閱且觀察到了消費者啟動的日誌行。問題是消費者依舊不會自動消費生產者提交的消息【通過DashBoard重新推送消息,此時消費者可以正常消費,只可以手動】
排查過程省略。暫時不再細究是為什麼,後面有空再說。
問題解決
SpringBoot版本和RocketMQ版本不合適,這裡先給出一套穩定的版本搭配,有更新更好的搭配歡迎指點。
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.12</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.2.0</version>
</dependency>