天天看點

MAC上安裝rocketmq磁盤空間不足的問題

一般的MAC電腦磁盤都不大,比如我公司的是256G,安裝完rocketmq後,報磁盤空間不足,類似的錯誤資訊見文檔末尾。

百度了許久也沒有找到滿意的答案,有人說清理磁盤,騰出20G空間……

其實沒有必要這樣,隻需要修改啟動腳本runbroker.sh,在裡面增加一句話即可:

JAVA_OPT="${JAVA_OPT} -Drocketmq.broker.diskSpaceWarningLevelRatio=0.98"

我這裡把磁盤保護的百分比設定成98%,隻有磁盤空間使用率達到98%時才拒絕接收producer消息。

原因如下圖所示,rocketmq預設的磁盤空間警戒水位是90%,而我的MAC常年使用率在94左右,

MAC上安裝rocketmq磁盤空間不足的問題

錯誤日志:

com.alibaba.rocketmq.client.exception.MQClientException: Send [] times, still failed, cost []ms, Topic: Name, BrokersSent: [hongwen.local, null, null]
See https://github.com/alibaba/RocketMQ/issues/ for further details.
    at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:)
    at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:)
    at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:)
    at com.alibaba.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:)
    at middleware.rmq.TestProducer.testProducer2(TestProducer.java:)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:)
    at java.lang.reflect.Method.invoke(Method.java:)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:)
    at org.junit.runners.ParentRunner$1.evaluate(ParentRunner.java:)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:)
    at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:)
Caused by: com.alibaba.rocketmq.client.exception.MQBrokerException: CODE:   DESC: service not available now, maybe disk full, CL:   CQ:   INDEX:  , maybe your broker machine memory too small.
For more information, please visit the url, https://github.com/alibaba/RocketMQ/issues/
    at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.processSendResponse(MQClientAPIImpl.java:)
    at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:)
    at com.alibaba.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:)
    at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:)
    at com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:)
    ...  more