问题标签 [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.

0 投票
1 回答
215 浏览

rocketmq - 如何直接通信rocketmq和rocketmq?

我有两个网络环境(例如NETWORK -ANETWORK -B)。现在,我在中部署了rocketmq-a,在中NETWORK-A 部署了rocketmq-b NETWORK-B,如何直接通信rocketmq-a和rocketmq-b? 在此处输入图像描述

0 投票
1 回答
1356 浏览

java - RocketMQ 域名服务器启动错误 -- 找不到或无法加载主类

我试图按照官方指南从头开始安装 RocketMQ ,我使用了 jdk 1.8.0_121 和 maven 3.5.0。

但是,在 step 之后mvn -Prelease-all -DskipTests clean install -U,没有distribution生成目录,所以cd distribution/target/apache-rocketmq不会成功。

然后我尝试通过键入直接启动名称服务器sh bin/mqnamesrv,它给了我以下错误。

我曾认为这可能是我的 CLASSPATH 环境变量的问题,但即使我设置它仍然无法正常工作。下面是我的配置

源代码是否有任何更新或文档中尚未出现的一些额外步骤,我想知道我是否遗漏了什么?

0 投票
0 回答
346 浏览

maven - mvn -Prelease-all -DskipTests clean install -U 时出错

标题说的问题

我使用的 RocketMQ 版本是从https://github.com/apache/incubator-rocketmq/tree/release-4.0.0-incubating下载的 incubator-rocketmq-release-4.0.0-incubating

当 mvn -Prelease-all -DskipTests clean install -U 时它有一些错误

0 投票
1 回答
188 浏览

rocketmq - RocketMQ 运行 runserver.sh 带 sh: /usr/local/rocketMQ/incubator-rocketmq/bin/runserver.sh: 没有那个文件或目录

RocketMQ 运行 runserver.sh 带 sh: /usr/local/rocketMQ/incubator-rocketmq/bin/runserver.sh: 没有那个文件或目录

怎么了?

我打开文件'runserver.sh'并运行'set ff'结果为fileformat = unix

0 投票
1 回答
648 浏览

rocketmq - 错误:无法找到或加载主类 org.apache.rocketmq.namesrv.NamesrvStartup

我按照快速入门指南https://rocketmq.incubator.apache.org/docs/quick-start/设置 RocketMQ ,运行

日志显示:
Java HotSpot(TM) Server VM 警告:忽略选项 PermSize=128m;在 8.0 中删除了支持

Java HotSpot(TM) 服务器虚拟机警告:忽略选项 MaxPermSize=320m;在 8.0 中删除了支持

Java HotSpot(TM) Server VM 警告:将 DefNew 年轻收集器与 CMS 收集器一起使用已被弃用,并且可能会在未来的版本中被删除

Java HotSpot(TM) Server VM 警告:UseCMSCompactAtFullCollection 已弃用,可能会在未来的版本中删除。

错误:无法找到或加载主类 org.apache.rocketmq.namesrv.NamesrvStartup

0 投票
1 回答
285 浏览

consumer - CONSUME_FROM_LAST 偏移量无效

在此处输入图像描述

我更改了我的消费组并开始消费,它默认从最后一个偏移量消费,这是正确的。

但是当我重新启动这个消费者时,它会使用历史消息,为什么它在第一次启动时不使用历史消息,而是第二次使用。

以及经纪人的抵消从3000到4000。

0 投票
1 回答
110 浏览

rocketmq - RocketMQ在.NET SDK中抛出System.TypeInitializationException异常的Demo示例

我正在运行为 .NET SDK RocketMQ 提供的演示示例。https://help.aliyun.com/document_detail/29561.html?spm=5176.doc29561.3.3.nIAzgT

但它抛出了以下异常。

我没有得到任何解决方案。任何人都可以为异常提供解决方案。

0 投票
0 回答
87 浏览

rocketmq - Service Fabric 中的 Apache RocketMQ 出现异常

我在服务结构应用程序中使用 RocketMQ。但是当我试图创建 ONSFactoryProperty 的实例时它会抛出异常;ONSFactoryProperty factoryInfo = 新 ONSFactoryProperty()

同样在创建 ONSFactory 实例时;ONSFactory onsfactory = 新 ONSFactory();

但是我在控制台应用程序中尝试过相同的代码。它工作正常。这个问题有什么解决方案吗?

0 投票
2 回答
464 浏览

apache - apache rockerMQ 代理无法启动

我尝试为 rockerMQ 代理加注星标,但收到错误消息:

Java 运行时环境没有足够的内存来继续。

本机内存分配 (mmap) 未能映射 8589934592 字节以提交保留内存。

包含更多信息的错误报告文件保存为:

/usr/local/soft/rocketMQ/incubator-rocketmq/distribution/target/apache-rocketmq/hs_err_pid6034.log

Java HotSpot(TM) 64 位服务器 VM 警告:INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) 失败;error='无法分配内存' (errno=12)

我从错误日志文件中得到了一些关于内存消息的信息:

内存:4k 页,物理 4089840k(551832k 免费),交换 2621432k(2621432k 免费) vm_info:用于 linux-amd64 JRE (1.8.0_144-b01) 的 Java HotSpot(TM) 64 位服务器 VM (25.144-b01),基于2017 年 7 月 21 日 21:57:33,“java_re”与 gcc 4.3.0 20080428 (Red Hat 4.3.0-8)

我怎样才能让rockerMQ代理为我工作

0 投票
1 回答
252 浏览

rocketmq - RocketMQ中如何设置topic的partition?

我正在使用 RocketMq 作为我的应用程序的消息传递层,我需要将创建的主题中的分区设置为一个。RocketMQ中如何设置topic的partition个数?