no message

docker-compose.yml

@@ -169,52 +169,53 @@ services:
     networks:
       - kxs_cloud_network
 
-#  kxs-rocket:
-#    image: apache/rocketmq:5.1.4
-#    hostname: kxs-rocket
-#    container_name: kxs-rocket
-#    ports:
-#      - 9876:9876
-#    volumes:
-#      - ./logs/rocket:/home/rocketmq/logs
-#    command: sh mqnamesrv
-#    restart: on-failure
-#    networks:
-#      - kxs_cloud_network
-#
-#  kxs-rocket-broker:
-#    image: apache/rocketmq:5.1.4
-#    hostname: kxs-rocket-broker
-#    container_name: kxs-rocket-broker
-#    ports:
-#      - 10909:10909
-#      - 10911:10911
-#      - 10912:10912
-#    environment:
-#      JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
-#    volumes:
-#      - ./data/broker/store:/home/rocketmq/store
-#      - ./kxs-visual/kxs-rocket/broker/broker.conf:/home/rocketmq/conf/broker.conf
-#    command: sh mqbroker -n kxs-rocket:9876 -c /home/rocketmq/conf/broker.conf
-#    restart: on-failure
-#    networks:
-#      - kxs_cloud_network
-#    depends_on:
-#      - kxs-rocket
-#
-#  kxs-rocket-dashboard:
-#    image: apacherocketmq/rocketmq-dashboard:1.0.0
-#    container_name: kxs-rocket-dashboard
-#    hostname: kxs-rocket-dashboard
-#    ports:
-#      - 9870:8080
-#    environment:
-#      - JAVA_OPTS=-Drocketmq.namesrv.addr=kxs-rocket:9876
-#    restart: on-failure
-#    depends_on:
-#      - kxs-rocket-broker
-#    networks:
-#      - kxs_cloud_network
+  kxs-rocket:
+    image: apache/rocketmq:5.1.0
+    hostname: kxs-rocket
+    container_name: kxs-rocket
+    ports:
+      - 9876:9876
+    volumes:
+      - ./logs/rocket:/home/rocketmq/logs
+    command: sh mqnamesrv
+    restart: on-failure
+    networks:
+      - kxs_cloud_network
+
+  kxs-rocket-broker:
+    image: apache/rocketmq:5.1.0
+    hostname: kxs-rocket-broker
+    container_name: kxs-rocket-broker
+    ports:
+      - 8081:8081
+      - 10909:10909
+      - 10911:10911
+      - 10912:10912
+    environment:
+      JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"
+    volumes:
+      - ./data/broker/store:/home/rocketmq/store
+      - ./kxs-visual/kxs-rocket/broker/broker.conf:/home/rocketmq/conf/broker.conf
+    command: sh mqbroker -n kxs-rocket:9876 -c /home/rocketmq/conf/broker.conf
+    restart: on-failure
+    networks:
+      - kxs_cloud_network
+    depends_on:
+      - kxs-rocket
+
+  kxs-rocket-dashboard:
+    image: apacherocketmq/rocketmq-dashboard:1.0.0
+    container_name: kxs-rocket-dashboard
+    hostname: kxs-rocket-dashboard
+    ports:
+      - 9870:8080
+    environment:
+      - JAVA_OPTS=-Drocketmq.namesrv.addr=kxs-rocket:9876
+    restart: on-failure
+    depends_on:
+      - kxs-rocket-broker
+    networks:
+      - kxs_cloud_network
 
 
 networks:

kxs-visual/kxs-rocket/broker/broker.conf

@@ -7,3 +7,11 @@ brokerRole = ASYNC_MASTER
 flushDiskType = ASYNC_FLUSH
 # 注意，宿主IP是你计算机网卡的IP
 brokerIP1 = 192.168.101.250
+# 在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
+defaultTopicQueueNums=4
+
+# 是否允许 Broker 自动创建 Topic，建议线下开启，线上关闭 ！！！这里仔细看是 false，false，false
+autoCreateTopicEnable=true
+
+# 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
+autoCreateSubscriptionGroup=true