-
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中创建数百万个主题 ....