问题标签 [rocketmq]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
rocketmq - RocketMQ集群中什么情况下消息不会被消费或延迟消费？
我在一个有六个节点的集群中有超过五百个主题，我创建这样的主题：
我可以毫不拖延地发送消息，但有时我发现客户端无法消费消息，因为代理没有消费客户端。如何修复这个错误？
apache-kafka - 如何在不允许发起连接的环境中部署 RocketMq 或 pulsar 等消息队列？
我需要向在不允许发起连接但接受连接的环境中运行的客户端发布消息。
对于 RocketMQ 或 pulsar，我遇到的问题是它们都需要客户端（或代理或代理）启动连接以注册自己。
想知道在这种情况下部署它们的正确方法是什么？或任何其他适合这种情况的类似软件？
spring - 未找到依赖项 'org.apache.rocketmq:rocketmq-spring-boot-starter:2.2.0'
org.apache.rocketmq:rocketmq-spring-boot-starter:2.2.0未找到依赖项
如图所示，我需要导入rocketmq的依赖。但是找不到IDE错误信息。
我怎么解决这个问题？
rocketmq - RocketMQ 报“no name server, please set it”即使显式设置了name server
它发生在 Spring-Boot + Dubbo 项目中。一个模块出现此类异常，而其他模块运行良好。这个异常也出现在测试用例中，但奇怪的是下面的代码应该在 main 方法中运行而没有任何问题。有没有人遇到过这样的问题，可以给我一些建议，非常感谢。
java - 错误：在 Windows 10 中无法找到或加载主类 org.apache.rocketmq.namesrv.NamesrvStartup
我按照快速启动https://rocketmq.apache.org/docs/quick-start/的指南在 Windows 10 中设置 RocketMQ-4.9.0 ，然后在 cmd 中运行 .\bin\mqnamesrv.cmd，它给了我错误
错误：无法找到或加载主类 org.apache.rocketmq.namesrv.NamesrvStartup
谁能帮我？谢谢。
java - 生产环境下Rocketmq broker进程内存比例问题
我的问题是：通过Linux系统命令查看的内存使用量与java内存各个区域的总使用量，以及哪个区域正在使用内存，存在巨大差异。
版本：
ps 辅助|grep java :
根 1408 4.4 60.7 33395552 19596884 ？Sl Mar22 7734:05 /bin/java -server -Xms1g -Xmx2g -Xmn1g -XX:+UseG1GC -XX:G1HeapRegionSize=16m -XX:G1ReservePercent=25 -XX:InitiatingHeapOccupancyPercent=30 -XX:SoftRefLRUPolicyMSPerMB=0 -verbose:gc -Xloggc:/dev/shm/mq_gc_%p.log -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+PrintGCApplicationStoppedTime -XX:+PrintAdaptiveSizePolicy -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=30m -XX:-OmitStackTraceInFastThrow -XX:+AlwaysPreTouch -XX:MaxDirectMemorySize=15g -XX:-UseLargePages -XX:-UseBiasedLocking -Djava.ext.dirs=/jre/lib/ext:/data/mq/rocketmq-all-4.5 .1-bin-release/bin/../lib -cp .:/data/mq/rocketmq-all-4.5.1-bin-release/bin/../conf: org.apache.rocketmq.broker.BrokerStartupautoCreateTopicEnable=true -c /data/mq/rocketmq-all-4.5.1-bin-release/conf/2m-noslave/broker-a.properties
PID：1408
最佳 ：
PID 用户 PR NI VIRT RES SHR S %CPU %MEM TIME+ 命令
1408 根 20 0 31.848g 0.018t 1.399g S 10.0 60.8 7734:02 java
RES：0.018吨
cat /proc/1408/status |grep 虚拟机：
VmRSS: 19603060 kB -> ~18G
我用上面的系统命令确定broker进程内存占用18G左右
实际分配给java的堆空间最大为2G -Xms1g -Xmx2g -Xmn1g
jstat -gc 1408 ：</p>
S0C S1C S0U S1U EC EU OC OU MC MU CCSC CCSU YGC YGCT FGC FGCT GCT
0.0 16384.0 0.0 16384.0 1097728.0 98304.0 442368.0 246238.9 79996.0 78497.1 10136.0 9709.5 111588 1343.763 0 0.000 1343.763
OC：432M S0C + S1C：32M EC：1072M MC：78M CCSC：9.8M
然后通过arthas工具：查看DirectMemory
直通：4M 映射：5154M
由上可知，java占用的内存大致为：
Javaheap + 元空间 + 线程数(217) * 256k + 代码缓存 + 直接内存 = 2 * 1024 + 78 + 217*256/1024 + 9.8 + 5 = 2194.8
即使包括映射的5154M，java进程也只有7348.8M
18G的比例差别很大。
这里的10G+差距是多少？
rocketmq - RocketMQ消息发出延迟消息，此后一直没有消息
问题：向rocketmq发送延迟消息后，达到延迟时间后，主题中没有发现发送的延迟消息 Attempt: Sending non-delayed messages are normal
java - RemotingTimeoutException：invokeSync 调用超时
使用springBoot RocketMQ4.9.0集成时，时不时提示下error Caused by: org. 阿帕奇。火箭MQ。远程处理。例外。RemotingTimeoutException：invokeSync 调用超时
java - 为什么找不到指定的程序？
- 我想开启rocketmq的异步刷盘，所以在broker.conf中配置transientstorepoolenable = true
- RocketMQ启动Broker时出现问题
- 我试图替换 msvcrt.dll 但它似乎没有用
系统环境：windows 10
RocketMQ中的代码抛出异常：
错误信息：
apache-kafka - RocketMQ和Kafka中如何实现顺序IO
在rocketmq和Kafka中如何实现顺序IO，因为在不同的操作系统中可能没有正好1g的连续地址磁盘空间。