Re: [D] rocketmq 5.2.0 消费者无法消费消息 [rocketmq]

[via GitHub]

GitHub user zhouhaibing edited a discussion: rocketmq 5.2.0  消费者无法消费消息

spring boot 版本  3.3
jdk版本 21
docker-compose部署文件
```   
version: '3.8'
services:
  namesrv:
    image: apache/rocketmq:5.2.0
    container_name: rmqnamesrv
    ports:
      - 9876:9876
    networks:
      - rocketmq
    command: sh mqnamesrv
  broker:
    image: apache/rocketmq:5.2.0
    container_name: rmqbroker
    ports:
      - 10909:10909
      - 10911:10911
      - 10912:10912
    volumes:
      - 
/root/deploy/rocketmq/conf/broker.conf:/home/rocketmq/rocketmq-5.2.0/conf/broker.conf
    environment:
      - NAMESRV_ADDR=rmqnamesrv:9876
    depends_on:
      - namesrv
    networks:
      - rocketmq
    command: sh mqbroker -c /home/rocketmq/rocketmq-5.2.0/conf/broker.conf
  proxy:
    image: apache/rocketmq:5.2.0
    container_name: rmqproxy
    networks:
      - rocketmq
    depends_on:
      - broker
      - namesrv
    ports:
      - 8181:8181
      - 8182:8182
    volumes:
      - 
/root/deploy/rocketmq/conf/proxy/proxy.json:/home/rocketmq/rocketmq-5.2.0/conf/proxy.json
    restart: on-failure
    environment:
      - NAMESRV_ADDR=rmqnamesrv:9876
    command: sh mqproxy -pc /home/rocketmq/rocketmq-5.2.0/conf/proxy.json
rmqconsole:
    image: apacherocketmq/rocketmq-dashboard
    container_name: rmqconsole
    ports:
      - 8087:8087
        #network_mode: "host"
        #privileged: true
    environment:
      JAVA_OPTS: -Dserver.port=8087 -Drocketmq.namesrv.addr=192.168.1.130:9876 
-Dcom.rocketmq.sendMessageWithVIPChannel=false 
-Drocketmq.config.accessKey=rocketmq2 -Drocketmq.config.secretKey=12345678
    volumes:
      - /docker/alibaba/rocketmq/console-ng/data:/tmp/rocketmq-console/data
    network_mode: "host"
    privileged: true
networks:
  rocketmq:
    driver: bridge
```

broker.conf文件
```
listenPort=10911
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
namesrvAddr = 192.168.1.130:9876
brokerIP1 = 192.168.1.130

# 是否允许broker自动创建Topic
autoCreateTopicEnable=true

#是否允许broker自动创建订阅组
autoCreateSubscriptionGroup=true
```

proxy.json文件
```
{
  "remotingListenPort":8181,
  "grpcServerPort":8182
}
```


发送消息代码
```
PatientInfoModifyMessage modifyMessage = new PatientInfoModifyMessage();
        modifyMessage.setBaseId("1949751120993714177");
        modifyMessage.setHospitalId(6);
        modifyMessage.setDiseaseType("T");
        SendReceipt sendReceipt = 
template.syncSendNormalMessage("PATIENT_INFO_MODIFY", 
JSON.toJSONString(modifyMessage));
```
消费消息代码
```
@RocketMQMessageListener(
        topic = MqConstants.PATIENT_INFO_MODIFY_TOPIC,
        consumerGroup = MqConstants.PATIENT_INFO_MODIFY_IM_WARN_GROUP
)
```

rocketmq 配置

```
rocketmq:
  producer:
    endpoints: 192.168.1.130:8182
    topic:
  push-consumer:
    endpoints: 192.168.1.130:8182
    access-key:
    secret-key:
    topic:
    tag: "*"
    request-timeout: 60
```

经调试，发送消息到mq是没问题的，在dashboard里面是可以查看到消息的
但是就是消费不了消息，服务运行没有任何异常

<img width="2515" height="456" alt="image" 
src="https://github.com/user-attachments/assets/f3680b15-3971-4fe5-bf2b-b93cacdb35e4";
 />




GitHub link: https://github.com/apache/rocketmq/discussions/9582

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org