Hacktoberfest 2026: le issue che i maintainer hanno segnato per ottobre, aperte e adatte ai principianti. Sfoglia le issue Hacktoberfest

namespave-v2 的配置无效

Aperta
#722 1 commento 0 reazioni 0 assegnatari Vedi su GitHub

Nessuno ha ancora preso questa issue.

Valutazione

Difficoltà
4/5
Tempo stimato
3-5 giorni
Idoneità per principianti
48/100
Tipo di issue
Bug
Chiarezza
Abbastanza chiara
Stato di attività
Tranquilla
Stack tecnologico
docker-compose, java, spring-boot

Direzione di ricerca

Iniziare con i file docker-compose.yml, broker.conf e YAML dell’applicazione Spring Boot forniti, utilizzando le versioni indicate di RocketMQ e rocketmq-spring-boot-starter. Riprodurre l’invio con namespace-v2 impostato su dev, quindi il consumo con quest’ultimo impostato su test, e confrontare il risultato con la configurazione del namespace. Il lavoro è completato quando i messaggi provenienti da dev sono isolati da test, come previsto dall’issue.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Descrizione

这是我的 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 可以实现消息隔离。

Lingua principale
Java
Stelle
2.3k
Fork
941
Metriche di merge delle PR
Nessuna PR unita negli ultimi 30g

Preparare l'ambiente

  • Nessun Dockerfile né file Docker Compose
  • Ha un modello di pull request
  • Nessuna guida per i contributori

Come iniziare

  1. Leggi tutta la issue e poi la guida ai contributi del progetto.
  2. Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
  3. Fai un fork del repository e lavora su un branch.
  4. Apri una pull request che faccia riferimento al numero della issue.

Altre issue di apache/rocketmq-spring

Tutte le issue di apache/rocketmq-spring

Issue simili

Altre issue su Java

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.