问答 2023-05-26 来自:开发者社区

pull方式消费,应用集群、mq集群如何管理offset

pull模式,应用集群,mq集群,怎么处理offset比较好,初步了解到使用RemoteBrokerOffsetStore,但是疑惑存储在本地的偏移量,因为应用是集群环境导致“各个本地”存储的offset乱套了。 原提问者GitHub用户githubyangxd

问答 2023-05-26 来自:开发者社区

当生产者发送批处理消息时,显示一个异常。RocketMQ集群是dledger模式,我能做什么

org.apache.rocketmq.client.exception.MQBrokerException: CODE: 13 DESC: the message is illegal, maybe msg body or properties length not matched. msg body length limit 128k, msg properties length limit....

问答 2023-05-26 来自:开发者社区

RocketMQ消息被发送到集群中的两个节点。消费者只能在一个节点上消费数据的原因是什么?

为什么broker2上的消息可以分发到上边而不能被订阅消费? 原提问者GitHub用户dawang1024

问答 2023-05-26 来自:开发者社区

我可以向同一组名称服务器注册多个代理集群吗?我可以在rocketmq面板上查看多个集群吗?我选择后没

我们的服务器资源丰富,所以我们希望在同三台服务器上构建多个集群。如果我使用同一组名称服务器,那么我在rocketmq面板上看到的代理组不会根据“brokerclustername”进行区分。它们混合在一起。尽管在控制台上可以看到多个集群名称,但页面在选择后不会更改。此外,代理被显示为一个意外的集群 原提问者GitHub用户sha-dow90

文章 2023-05-26 来自:开发者社区

Java 最常见的面试题:rabbitmq 集群有什么用?

集群主要有以下两个用途: 高可用:某个服务器出现问题,整个 RabbitMQ 还可以继续使用;高容量:集群可以承载更多的消息量。

文章 2023-05-18 来自:开发者社区

RabbitMQ集群的部署

10.1 clustering10.1.1  使用集群的原因最开始我们介绍了如何安装及运行 RabbitMQ 服务,不过这些是单机版的,无法满足目前真实应用的要求。如果 RabbitMQ 服务器遇到内存崩溃、机器掉电或者主板故障等情况,该怎么办?单台 RabbitMQ 服务器可以满足每秒 1000 条消息的吞吐量,那么如果应用需要 RabbitMQ 服务满足每秒 10 万条消息的吞吐量....

RabbitMQ集群的部署
文章 2023-05-18 来自:开发者社区

rabbitmq在linux中实现多机多可用集群

环境:centos7、erlang18.3、rabbitmq3.6.12本次采用多机多可用方式作为实例:1.1.准备多台服务器,安装好erlang和rabbitmq,保证服务启动后可以出现图像化界面。1.2.检查服务器上的rabbitmq的历史记录是否存在,清除该路径下的所有文件rabbitmq/var/lib/rabbitmq/mnesia1.3.设置erlang.cookie保证不同节点的e....

rabbitmq在linux中实现多机多可用集群
问答 2023-05-08 来自:开发者社区

canal server对接RocketMq没有使用rocketmq集群

环境信息 canal version 1.1.3 mysql version 5.7.20 问题描述 canal server 对接RocketMQ集群(2主2从模式),集群中两个主broker上都创建了同一个topic,但是canal server 写消息到RocketMQ集群时固定只写入其中一个broker,没有往两个broker中的topic分配数据 原提问者GitHub用户flackya....

问答 2023-05-08 来自:开发者社区

canal server对接RocketMQ集群环境,使用partitionHash, 但是数据一直

环境信息 canal version 1.1.3 mysql version 5.7.20 问题描述 Canal Server 对接 RocketMQ集群环境(2主2从集群,Broker a 和 Broker b),instance.properties配置信息如下 mq config canal.mq.topic=example canal.mq.dynamicTopic=.\.. #cana....

问答 2023-05-01 来自:开发者社区

在Apache RocketMQ5.0的集群里面 这个rocketmq-exporter的源码是对的

在Apache RocketMQ5.0的集群里面 这个rocketmq-exporter的源码是对的 没有拼写错误 我调试了一下 从kvTable.getTable()里面拥有的的key就是"getTransferredTps" 其他版本不清楚这个地方是否有问题

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。