请教RocketMQ消费问题

环境:消费方在我们的服务器,生产方在客户服务器

问题:消费者不能消费消息。

已尝试方法:

1、客户方自己写的消费能消费,放到我们项目里在服务器启动,就不能消费。

2、我把我们项目中消费的代码,单独提出来部署了一个项目,可以消费,但是我们的项目启动还是不会消费。

请教下造成这种情况的原因及解决思路!   十分感谢

 

感觉是你们的项目,没有启动这个消费者啊。

集成到你们项目的时候,能看到消费者启动的日志吗,就是分配了哪个分区,开始消费那种日志

已自行解决 

原因是我们本地项目配了生产者和消费者

但是生产者的地址不通   

之前没找到原因 是因为没有异常发生,项目没有抛异常

经过对springboot的启动日志进行分析    发现MQ打印了一个日志 ,网上查询了日志的分析,就是生产者没通,去测了下,还真是,之后改成消费者一样的地址   重启  

问题解决