问题标签 [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 回答
217 浏览

rocketmq - 当消费者组启动时,出现错误“CODE:22 Not found, V3_0_6_SNAPSHOT may this group consumer boot first”,RocketMQ

版本:3.2.6

消费者类型:PullConsumer

当一个新的消费者启动时,我将尝试从 mq 获取消费者偏移量:

但我碰巧遇到这个返回-1,我看到了错误:

从错误日志。

0 投票
1 回答
461 浏览

rocketmq - RocketMQ:一个topic的队列是如何映射到master broker的?

据我所知,在 RocketMq 中,“队列”类似于 Kafka 中的“分区”。一个主题有多个队列,也有多个代理(主从)。

但是队列是如何映射到主控的呢?

例如,如果我有一个包含 3 个队列和 3 个主控的主题。3 个队列分布在 3 个主控之间?或者每个主人有3个队列?

0 投票
1 回答
361 浏览

rocketmq - consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET) 没用

我想从最后一个偏移量读取数据,但使用:

没有效果。

0 投票
1 回答
110 浏览

rocketmq - 消费offset Diff为负,有什么可能的原因?

有时会出现consume offset和broker offset的diff为负数的情况,这是非常不正常的。

社区中有很多用户遇到了这个问题。

这个问题是列出所有可能的原因和解决方案。

在此处输入图像描述

0 投票
1 回答
150 浏览

rocketmq - 如何知道哪个队列分配给了哪个consumer-RocketMQ?

消费者队列是在客户端分配的,代理对此一无所知。

那么我们如何监控哪个队列分配给哪个消费者客户端呢?

0 投票
1 回答
237 浏览

rocketmq - RocketMQ 支持主从自动切换吗?

RocketMQ 支持主从自动切换吗?我已经在 v3.5.8 中尝试过,但它不起作用。所以,我只想问一个能给出准确答案的人

0 投票
1 回答
200 浏览

rocketmq - RocketMq QuickStart runbroker.sh 设置过大的 java 堆

当我提到 Rocket mq 快速启动时,我按照提示:下载源代码和构建,运行 sh 启动代理,我从 os. 所以我检查了shell脚本,发现堆大小默认设置为8g。这对于开发机器来说太大了吗?当我使用 maven 构建整个项目时,我也感到困惑,由于 maven 构建项目需要 1g 的堆大小,再次从 os 获得了被杀死的提示。我认为 Rocket mq 的文档应该提到这些,以帮助开发人员真正快速入门。

0 投票
1 回答
154 浏览

java - RocketMQ中如何配置2个broker之间的消息通道

我们使用 ActiveMQ 配置网络连接器来实​​现 2 个 broker 之间的消息通道,现在我们想使用 RocketMQ。但是我看了很多文章,RocketMQ中似乎没有像WebSphere MQ那样的“通道”或像ActiveMQ这样的“网络连接器”的概念。那么如何在 RockemtMQ 中配置 2 个 broker 之间的消息通道呢?或者如何在 RocketMQ 中实现 WMQ 或 AMQ 之类的“通道”场景?

0 投票
2 回答
1514 浏览

rocketmq - Rocketmq:MQBrokerException:代码:2 DESC:[TIMEOUT_CLEAN_QUEUE]

当我向代理发送消息时,偶尔会发生此异常。

这意味着代理太忙(当 tps>1,5000 时)无法处理如此多的发送消息请求。造成这种情况的最不可能的原因是什么?磁盘,cpu或其他东西?我该如何解决?

0 投票
1 回答
360 浏览

rocketmq - RocketMQ生产者可以发送多标签消息吗?

RocketMQ 消费者可以像这样订阅带有多个标签的主题

生产者如何发送taga消息tagb

我尝试发送带有标签“taga||tagb”的消息,但消费者没有收到任何消息。当我通过 msg_id 查询消息时,标签是[taga||tagb],而不是 ["taga", "tagb"]