RocketMQ 发送消息

问题遇到的现象和发生背景

RocketMQ 发送消息后 磁盘空间不足

问题相关代码,请勿粘贴截图

RocketMQ NameSrv启动成功,Broker启动成功,普通消息发送成功

public static void main(String[] args) throws Exception {
        DefaultMQProducer producer = new DefaultMQProducer("group_a");
        producer.setNamesrvAddr("127.0.0.1:9876");
        producer.start();
        for (int i = 1; i < 11; i++) {
            String topic = "TopicA";
            String tags = "TagA";
            String str = "Hello RocketMQ The index " + i;
            Message message = new Message(topic, tags, str.getBytes(RemotingHelper.DEFAULT_CHARSET));
            SendResult result = producer.send(message);
            System.out.println(i + ":" + result);
        }
        producer.shutdown();
    }
运行结果及报错内容

1.控制台效果貌似正确

img


2.网页控制台感觉不对

img


3.硬盘中的index文件夹在递归写入

img

NameSrv和Broker是通过源代码方式在windows启动的,如果在Linux中使用是正确的