namespave-v2 的配置无效

Abierto
  • ¿Algo no está bien?
#722 1 comentario 0 reacciones 0 asignados Ver en GitHub

Nadie ha tomado este issue todavía.

Evaluación

Dificultad
4/5
Tiempo estimado
3-5 días
Aptitud para principiantes
48/100
Tipo de issue
Error
Claridad
Bastante claro
Estado de actividad
Tranquilo
Stack tecnológico
docker-compose, java, spring-boot
Área
backend, distributed-systems

Línea de trabajo

Comience con los archivos docker-compose.yml, broker.conf y YAML de la aplicación Spring Boot proporcionados, utilizando las versiones indicadas de RocketMQ y rocketmq-spring-boot-starter. Reproduzca el envío con namespace-v2 establecido en dev y, después, el consumo con este establecido en test; compare esto con la configuración del namespace. Se considera terminado cuando los mensajes de dev están aislados de test, tal como espera el issue.

Escrito por el modelo de indexación a partir del texto del issue.

Descripción

这是我的 docker-compose.yml

services:
  namesrv:
    image: apache/rocketmq:5.3.1
    container_name: rmqnamesrv
    restart: on-failure
    volumes:
      - ./logs/namesrv:/home/rocketmq/logs
    ports:
      - 9876:9876
    networks:
      - rocketmq
    command: sh mqnamesrv

  broker:
    image: apache/rocketmq:5.3.1 
    container_name: rmqbroker 
    restart: on-failure
    ports:
      - 10909:10909
      - 10911:10911
      - 10912:10912
    environment:
      - NAMESRV_ADDR=namesrv:9876  
      - JAVA_OPT_EXT=-server -Xms512m -Xmx512m -Duser.home=/home/rocketmq 
    volumes:
      - ./broker_master/store:/home/rocketmq/store
      - ./broker_master/broker.conf:/home/rocketmq/rocketmq-5.3.1/conf/broker.conf
      - ./logs/broker:/home/rocketmq/logs
    depends_on:
      - namesrv 
    networks:
      - rocketmq  
    command: sh mqbroker -c ../conf/broker.conf 

networks:
  rocketmq:
    name: rocketmq
    driver: bridge

这是我的 broker.conf

brokerClusterName=DefaultCluster
brokerName=Broker-A
brokerId=0
deleteWhen=03
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
listenPort=10911
brokerIP1=192.168.30.12
namesrvAddr=192.168.30.12:9876

spring boot version: 3.4.4
rocketmq-spring-boot-starter version: 2.3.3

rocketmq:
  name-server: 192.168.30.12:9876
  producer:
    group: producer
    namespace-v2: test
  consumer:
    group: consumer
    namespace-v2: test

修改 namespace-v2 为 dev 发送消息，修改 namespace-v2 为 test，在 namespace-v2 为 test 的情况下消费消息，会消费到 dev 的消息，使用 namespace 可以实现消息隔离。

Lenguaje dominante
Java
Estrellas
2.3k
Forks
941
Sin PR fusionados en 30 d

Preparar el entorno

  • Sin Dockerfile ni archivo de Docker Compose
  • Tiene una plantilla de pull request
  • Sin guía de contribución

Primeros pasos

  1. Lee el issue completo y luego la guía de contribución del proyecto.
  2. Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
  3. Haz un fork del repositorio y trabaja en una rama.
  4. Abre un pull request que haga referencia al número del issue.

Más de apache/rocketmq-spring

Todos los issues de apache/rocketmq-spring

Issues similares

Más issues de Java

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.