原文:RocketMQ 创建和删除 topic,以及 broker 和 nameserver 之间的心跳

命令行主类:org.apache.rocketmq.tools.command.MQAdminStartup 客户端创建 topic 程序参数:updateTopic n localhost: c DefaultCluster t topic zhang org.apache.rocketmq.tools.command.topic.UpdateTopicSubCommand execute创建 ...

2019-09-09 15:55 0 1650 推荐指数:

查看详情

深入理解RocketMQ的消费者组、队列、BrokerTopic

1、遇到的问题:上测试环境,上次描述的鸟问题又出现了,就是生产者发3条数据,我这边只能收到1条数据。 2、问题解决:   (1)去控制台看我的消费者启动情况,貌似没什么问题 ,   (2)去测 ...

Tue Oct 15 23:06:00 CST 2019 0 3754
本地启动 NameServerBroker | 读 RocketMQ 源码前的准备工作

clone 并导入源码 本地启动 NameServer 本地启动 Broker 本地运行生产者与消费者代码 完成上述步骤之后,RocketMQ的源码环境就搭建完毕了,之后就可以在本地启动以及收发消息,调试和分析RocketMQ的源码了。 clone 并导入源码 ...

Wed Jul 01 05:11:00 CST 2020 0 906
RocketMQ(4.8.0)——Broker 过期文件删除机制

Broker 过期文件删除机制   RocketMQ 中主要保存了 CommitLog、Consume Queue、Index File 三种数据文件。由于内存和磁盘都是有限的资源,Broker 不可能永久地保存所有数据,所以一些超过保存期限的数据会被定期删除RocketMQ 通过设置数据过期 ...

Tue Mar 02 04:42:00 CST 2021 0 300
🏆【Alibaba中间件技术系列】「RocketMQ技术专题」Broker服务端自动创建topic的原理分析和问题要点指南

前提背景 使用RocketMQ进行发消息时,一般我们是必须要指定topic,此外topic必须要提前建立,但是topic创建(自动或者手动方式)的设置有一个开关autoCreateTopicEnable,此部分主要会在broker节点的配置文件的时候进行设置,运行环境中会使用默认设置 ...

Thu Jan 20 03:49:00 CST 2022 0 737
RocketMQ:(2) Broker

  BrokerRocketMQ的核心,大部分“重量级”工作都是由Broker完成的,包括接收Producer发过来的信息、处理Consumer的消费消息请求、消息的持久化存储、消息的HA机制以及服务端过滤功能等。 一、消息存储文件   分布式队列因为有高可靠性的要求,所以数据要通过磁盘进行 ...

Sat Jul 17 23:39:00 CST 2021 0 253
rocketMQ手动创建Topic

参数解释如下: 在灰度环境扩展消费者机器,需要手动创建Topic,命令如下: ...

Thu Oct 29 00:05:00 CST 2020 0 7008
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM