【rocket-mq】消息发送报错:the broker‘s disk is full

这篇具有很好参考价值的文章主要介绍了【rocket-mq】消息发送报错:the broker‘s disk is full。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

在本地windows系统上测试rocketmq,根据文档启动nameserver和broker后,编写用例测试消息发送,一直报以下错误,使用rocketmq自带的tools.cmd也是一样:

Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [781]ms, Topic: bingheTopic, BrokersSent: …………
Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 14  DESC: service not available now. It may be caused by one of the following reasons: 
the broker's disk is full [CL:  0.93 CQ:  0.93 INDEX: -1.00], messages are put to the slave, message store has been shut down, etc.

查看本地所有磁盘发现都还剩余空间,只是c盘最紧张,不过也显示还有10G左右。尝试网上的修改报错阈值:

# linux
JAVA_OPT="${JAVA_OPT} -Drocketmq.broker.diskSpaceWarningLevelRatio=0.99"

# windows
set "JAVA_OPT=%JAVA_OPT% -Drocketmq.broker.diskSpaceWarningLevelRatio=0.99"

仍未生效,最后关掉了其他几个应用之后,c盘空间恢复一些重试成功。

原因分析:

idea默认启动java进程使用的是4G最大堆内存,本地使用idea启动了三个应用,除此之外还有其他服务。内存不够导致通过c盘的磁盘空间交换出来了,在rocketmq消息处理过程中会检查磁盘是否还有还有剩余,如果达不到阈值则直接抛出以上异常。

【rocket-mq】消息发送报错:the broker‘s disk is full,rocket-mq,java,开发语言

彻底的解决方式是:在idea开启服务进程的时候,增加最大堆内存限制:-Xmx250m,这样就保证了c盘磁盘空间的剩余容量。文章来源地址https://www.toymoban.com/news/detail-562553.html

到了这里,关于【rocket-mq】消息发送报错:the broker‘s disk is full的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 【Vivado】Ubuntu22.10安装Vivado2022.2报错the disk is full, you‘ve exceeded disk quota及无法启动解决

    There was an error extracting files Error was encountered while extracting archive …/2022.2/payload/rdi_0931_2022.2_1014_8888.xz The possible reasons can be: the disk is full, you’ve exceeded disk quota, or the destination directory is too long. 参考Vitis Installation Failure - Error -7 while trying to extract .xz file,软件不能安装在NTFS分区。

    2024年02月04日
    浏览(500)
  • 什么是mq?可靠性、重复消息、重复消费、丢失、发送大文件、延迟、发送机制、重试、死信、幂等、有序、大小、过期、优先级、进了死信队列还能出来吗?

    “MQ” 指的是消息队列(Message Queue),是一种用于异步通信的技术。消息队列是一种中间件,用于在分布式系统中传递消息,使不同组件之间能够进行松散耦合的通信。它的核心思想是生产者将消息发送到队列,而消费者从队列中接收并处理消息。 消息队列的主要优点包括

    2024年02月06日
    浏览(38)
  • Rocket重试机制,消息模式,刷盘方式

    一、 Consumer 批量消费(推模式) Consumer 端先启动   Consumer 端后启动 . 正常情况下:应该是 Consumer 需要先启动 consumer.setConsumeMessageBatchMaxSize(10);// 每次拉取 10 条 package quickstart; import java.util.List; import com.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer; import com.alibaba.rocketmq.client.con

    2024年02月07日
    浏览(24)
  • kafka消费/发送消息,消息过大报错解决whose size is larger than the fetch size 1048576

    一、kafka消费报错原因 问题原因一:个是kafka本身的配置没有调整到上限 问题原因二:就是我们自己写python消费kafka代码的时候没有参数配置没有限制 RecordTooLargeError: (\\\"There are some messages at [Partition=Offset]: {TopicPartition(topic=\\\'psadad\\\', partition=1): 75} whose size is larger than the fetch size 1

    2024年02月07日
    浏览(36)
  • 阿里云MQ报错:The AMQP operation was interrupted: AMQP close-reason, initiated by Peer, code=403

    报错截图: The AMQP operation was interrupted: AMQP close-reason, initiated by Peer, code=403, text=\\\'AccessDeniedByRamPolicy, ReqId:639816A74146313600B7647E\\\', classId=10, methodId=40 处理方法:  AMQP协议返回码:   打开RAM控制台。选择“用户”,单击对应的用户名,在“权限管理”添加“AliyunAMQPFullA

    2024年02月16日
    浏览(62)
  • RocketMQ源码阅读-Broker消息接收

    Broker接收 Producer 发送的消息。 Broker在RocketMQ中也是一个独立的Model,rocketmq-broker。 Broker的核心类为SendMessageProcessor。 同样从单元测试入手,看Broker接收消息的流程。 SendMessageProcessor的单元测试类为org.apache.rocketmq.broker.processor.SendMessageProcessorTest。 包含上面这些方法,其中ini

    2024年01月17日
    浏览(25)
  • 服务端发送消息给客户端失败java.lang.IllegalStateException: The remote endpoint was in state [TEXT_FULL_WRITING]

    The remote endpoint was in state [TEXT_FULL_WRITING] which is an invalid state for called method的问题在于: handlerA和handlerB两个方法有可能同时执行,当A或者B方法遍历到某一个session并且调用sendMessage发送消息的时候,另外一个方法也正好也在使用相同的session发送另外一个消息(同一个session消息发

    2024年02月16日
    浏览(38)
  • QQ 邮箱使用 SMTP 发送邮件报错:550 The From header is missing or invalid

    QQ 邮箱使用 SMTP 发送邮件报错: 550 The From header is missing or invalid : 源码( pthon 3.12 ) 看到 QQ 邮箱对 header 中的 from 有合法性校验,我们的字段格式符合要求,怀疑是字符编码问题。 通过打印封装的 message 查看我们的 From 字段乱码,去掉 utf-8 编码。 再次测试,正常发送邮件

    2024年04月16日
    浏览(65)
  • 【Ubuntu搭建MQTT Broker及面板+发布消息、订阅主题】

    根据自己的服务器是否开始了防火墙放行端口(18083 默认面板端口) 访问:域名:18083 用户名是admin,初始密码是public。登陆后需要立即修改密码,还可以新增用户 至此搭建完成,我们使用本地的进行发布订阅测试 最后一个免费版本下载点击链接下载 https://newbie-typora.oss-cn-

    2024年02月09日
    浏览(27)
  • MQ消息队列详解以及MQ重复消费问题

    https://blog.csdn.net/qq_44240587/article/details/104630567 核心的就是:解耦、异步、削锋 现有ABCDE五个系统,最初的时候BCD三个系统都要调用A系统的接口获取数据,一切都很正常,但是突然,D系统说:我不要了,你不用给我传数据了,A系统无奈,只能修改代码,将调用D系统的代码删除

    2024年04月13日
    浏览(43)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包