RocketMQ 发送消息

Question

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

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.控制台效果貌似正确

2.网页控制台感觉不对

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

Answer 1

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