-
0 votesanswersviews
为什么ProducerManager.getGroupChannelTable（）只返回rocketmq中的groupChannelTable？
下面是getGroupChannelTable（）的实现，我想知道为什么不只是返回groupChannelTable： https://github.com/apache/rocketmq/blob/master/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java private final Has... -
0 votesanswersviews
RocketMQ 生产环境 者可以发送带有多个标签的消息吗？
RocketMQ消费者可以使用这样的多个标签订阅主题 consumer.subscribe("topic", "taga||tagb"); 生产环境 者如何使用 taga 和 tagb 发送消息 我尝试发送带有标签"taga||tagb"的消息，但消费者没有收到任何消息 . 当我通过msg_id查询消息时，标签是 [taga||tagb... -
-1 votesanswersviews
如何在RocketMQ中设置主题中的分区？
我使用RocketMq作为我的应用程序的消息传递层，我需要将创建的主题中的分区设置为一个 . 如何在RocketMQ中设置主题分区数？ -
0 votesanswersviews
并行消息发送到RocketMQ代理抛出异常
我的Rocket MQ 生产环境 者正在500个主题并行发送500条消息 . 但是对于某些主题的消息发送时间，它正在抛出异常，“此主题没有路由信息”但该主题已经创建 . 我已经在topics.json文件以及RocketMQ控制台中验证了它 . 首先我要创建主题： _producer.createTopic(DEFAULT_TOPIC, topicName, 4); 然后我发送消息： Messa... -
0 votesanswersviews
如何在％DLQ％中处理邮件
我正在尝试使用％DLQ％中的消息，但失败了 . 它 08:33:30.588 [RebalanceService] ERROR RocketmqClient - AllocateMessageQueueStrategy.allocate Exception. allocateMessageQueueStrategyName=AVG java.lang.IllegalArgumentExceptio... -
4 votesanswersviews
为什么Thread.sleep（0）可以阻止rocketmq中的gc？
最近我在RocketMQ中阅读了源代码，但我无法理解这段代码 . 为什么这段代码可以阻止gc？ https://github.com/apache/rocketmq/blob/master/store/src/main/java/org/apache/rocketmq/store/MappedFile.java for (int i = 0, j = 0; i < this.fileSize... -
1 votesanswersviews
如何将RocketMQ代理与RocketMQ控制台连接以获取详细信息？
我是Apache RocketMQ的新手 . 我发现我们可以使用RocketMQ控制台来获取RocketMQ消息事务的详细信息 . see here 如何将该控制台与我本地运行的RockerMQ代理连接（同步）？ 我正在使用this documentation来运行代理和客户端 . -
0 votesanswersviews
RocketMQ中的异常： 生产环境 者服务状态不正常，START_FAILED
RocketMQ Broker和NameServer正在Running.Message 生产环境 和消费也工作正常 . 但有时我得到例外： 生产环境 者服务状态不行，START_FAILED . 任何人都可以告诉问题的原因，我该如何解决？ -
0 votesanswersviews
rocketMQ [TIMEOUT_CLEAN_QUEUE]经纪人忙，启动流量控制一段时间
当我向经纪人发送消息时，偶尔会发生此异常 . MQBrokerException：CODE：2 DESC：[TIMEOUT_CLEAN_QUEUE]代理忙，启动流量控制一段时间 我该如何解决？ -
-1 votesanswersviews
如何直接通信rocketmq和rocketmq？
我有两个网络环境（例如 NETWORK -A 和 NETWORK -B ） . 现在，我在 NETWORK-A 部署了rocketmq-a并在_2524404中部署了rocketmq-b，如何直接与rocketmq-a和rocketmq-b进行通信？ -
0 votesanswersviews
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 votesanswersviews
当消费者开始时，警告：“消费者的订阅不是最新的”
当我开始一个新的RocketMQ消费者时，消费者应立即启动并从代理中提取消息，但我发现警告登录代理和消费者日志： consumer start failed:CODE: 25 DESC: the consumer's subscription not latest 我认为消费者参与了消费者群体的活跃重新 balancer ，然后使用当前时间戳和通知经纪人进行subVersion更新 . 当拉消息请... -
0 votesanswersviews
无需停机即可升级RocketMQ版本
我们正在 生产环境 Rocketmq集群 . 我需要在没有Rocketmq集群停机的情况下将RocketMQ版本从4.2.0升级到4.3.0 . 这可以实现吗？如果是这样，请分享与版本迁移相关的任何链接，以便我可以关注它... -
0 votesanswersviews
远程连接异常 - 连接到服务器失败
我在macOS Sierra（10.12.3）上设置了RocketMQ（4.1.0-incubating-release），并根据this instruction启动了它的名称服务器和代理 . 名称服务器和代理启动良好 . 但是，我无法创建新主题或查看主题列表或查看任何主题的状态 . 我收到以下错误 . $ sh bin/mqadmin updateTopic -n localhost:9876 ... -
0 votesanswersviews
得到错误“CODE：22未找到，V3_0_6_SNAPSHOT可能是这个群组消费者首先启动”当一个消费者群体启动时，RocketMQ
版本：3.2.6 消费者类型：PullConsumer 当新的消费者引导时，我将尝试从mq获取消费者偏移量： long offset = pullConsumer.fetchConsumeOffset(mq, true) ; 但我碰巧遇到这个返回-1，我看到错误： CODE: 22 Not found, V3_0_6_SNAPSHOT maybe this group consumer boot... -
-1 votesanswersviews
RocketMQ消费者请求偏移量远大于代理中的最大偏移量，消费者差异量为负值
RocketMQ版本：3.2.6 我们的集群： 2 NameServer 6 Master Broker 6奴隶经纪人 我们有很多消费者（约100个）消费来自经纪人的消息， 我们使用命令监视消费差异命令：/ data / alibaba-rocketmq / bin / mqadmin consumerProgress -n XXX：XX差异为负（例如：-89823239112... -
1 votesanswersviews
apache rockerMQ经纪人无法启动
我试图为rockerMQ经纪人担任主角，但我收到了错误消息： Java Runtime Environment没有足够的内存来继续 . 本机内存分配（mmap）无法映射8589934592字节以提交保留内存 . 包含更多信息的错误报告文件保存为：/usr/local/soft/rocketMQ/incubator-rocketmq/distribution/target/apache-rocke... -
0 votesanswersviews
设置RocketMQ集群：slave不可见且不复制
我正在尝试 Build 一个RocketMQ集群，其中包含一个名称服务器，一个主服务器和两个从服务器 . 但是，我遇到了一些问题 . 我正在运行的版本是从github/rocketmq-all-4.1.0-incubating.zip下载的 . 代理使用 mqbroker -c broker.conf 运行，其中broker.conf对主服务器和从服务器不同 . 对于大师我有： listenPor... -
1 votesanswersviews
RocketMQ是否支持主从自动切换？
RocketMQ是否支持主从自动切换？我在v3.5.8中尝试过，但它不起作用 . 所以，我只想问一个能给出准确答案的人 -
0 votesanswersviews
rocketmq创建映射文件失败，服务器忙或坏
我的操作系统是Windows 7，我从apache rocket克隆了主分支的源代码，然后按照快速启动doc（https://rocketmq.apache.org/docs/quick-start/),every,every)就好了，直到我运行 生产环境 者的例子 . 以下是异常细节，我从各处搜索过，我无法找到解决方案，请帮助：org.apache.rocketmq.client.excepti... -
0 votesanswersviews
rocketmq CODE：206和CODE 207都在日志中：未找到使用者组使用统计信息，因为返回偏移表为空
在火箭控制台日志中找到了这个 org.apache.rocketmq.client.exception.MQClientException：CODE：206 DESC：未找到使用者组使用统计信息，因为返回偏移表为空，可能是消费者不使用任何消息 主题名称：BillDayInterestBatchJobDestination_topic 生产环境 者已经发送消息成功，但消费者无法消费 . [201... -
3 votesanswersviews
Apache Pulsar与Apache RocketMQ
Apache Pulsar（雅虎）似乎是下一代Apache Kafka . Apache RocketMQ（阿里巴巴）似乎是下一代Apache ActiveMQ . 两者都是开源分布式消息传递和流数据平台 . 但他们如何比较？在功能和性能方面我应该何时更喜欢一个？ Pulsar（和Kafka一样）在流媒体方面是否更加优秀，而RocketMQ（如ActiveMQ）在消息传递方面更加优秀？ -
0 votesanswersviews
RocketMQ中的多个消费者线程可以使用队列吗？
我现在正在学习rocketmq，一个主题将默认创建4个队列，如果消费者有5个线程，我想同时一个队列可以被2个线程消耗吗？如果是这样，rocketmq如何避免消息被消耗多次？ -
0 votesanswersviews
Rocketmq在代理conf中动态分配nameserver_ip
我正在Azure负载均衡器后面进行rocketmq的集群设置 . 我希望在代理中传递负载均衡器IP，而不是直接提供名称服务器IP . 因此，我可以删除IP的手动添加，并且可以轻松添加多个节点而无需重新启动任何服务 . 我发现有一个HTTP endpoints ，但不知道如何使用它 . https://rocketmq.apache.org/rocketmq/four-methods-to-feed... -
1 votesanswersviews
RocketMQ：如何将主题的队列映射到主代理？
据我所知，在RocketMq中，“队列”类似于Kafka中的“分区” . 一个主题有多个队列，也有多个代理（主服务器和从服务器） . 但是如何将队列映射到主人？ 例如，如果我有一个包含3个队列和3个主人的主题 . 3个队列分布在3个大师中？或者每个主人有3个队列？ -
1 votesanswersviews
如何在RocketMQ中的2个代理之间配置消息通道
我们使用ActiveMQ配置网络连接器以实现2个代理之间的消息通道，现在我们要使用RocketMQ . 但是我读了很多文章，似乎没有关于像WebSphere MQ这样的'Channel'或像RocketMQ中的ActiveMQ那样的'Network Connector'的概念 . 那么如何在RockemtMQ中的2个代理之间配置消息通道呢？或者如何在RocketMQ中实现像WMQ或AMQ这样的“ ... -
1 votesanswersviews
RocketMQ订单消息不起作用
我正在使用RocketMQ并且想要有序地生成和使用数据 . 我已经完成了订单示例：https://rocketmq.apache.org/docs/order-example/ 但在消费者倾听者中，消息并不是有序的 . 任何人都能说出这个Order消息是如何工作的吗？ -
0 votesanswersviews
在rocketmq中标记碰撞
RocketMQ支持按标签过滤，我将深入研究Broker的源代码 . 经纪人似乎做了以下比较： subscriptionData.getCodeSet().contains(tagsCode.intValue()); 在 org.apache.rocketmq.broker.filter.ExpressionMessageFilter#isMatchedByConsumeQueue . 所以我想... -
0 votesanswersviews
我的rocketMQ 2m-noslave不能消费消息
我在我的服务器上构建了一个rocketmq服务器，它是2m-noslave集群，它可以发送消息给rocketmq，但我的消费者无法接收消息，有人告诉我哪里出错了，认为......这是我的消费者CLass代码： public class Consumer{ public static final String CONSUMER_GROUP_NAME = "broker-b&quo... -
1 votesanswersviews
创建新主题的性能问题
目前，我们的VM配置了18GB内存，8核CPU . 我们在同一台机器上运行代理和名称服务器 . 截至目前，我们有大约3563个主题 . 因此，名称服务器和代理从18GB消耗13 GB . 我在创建新主题时面临延迟问题 . （对于创建它的新主题需要大约13到15秒） . 我期待在第二部分中创建一个主题 . 我可以知道这个延迟问题的原因吗？ 快速说明：我们希望在RocketMQ中创建数百万个主题 ....