在Kafka中，文件的布局采用了Topic/Partition的方式，每个分区对应一个物理文件夹，且在分区文件级别上实现了顺序写入。然而，当一个Kafka集群拥有大量的主题和每个主题拥有数百个分区时，在高并发写入消息的情况下，IO操作会变...

一个集群无Slave，全是Master，例如2个Master或者3个Master，这种模式的优缺点如下：

以下全部操作在的目录在：/etc/rocketmq, 并且Namesrv、Broker、Dashboard在同一个机器上

一：Topic不存在，即没有创建出来次Topic(我们项目均为手动创建)，或者Broker模块不支持自动创建topic。

org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java

RocketMQ 是一款高性能、可扩展的分布式消息中间件，目前已经成为各大互联网公司的主流解决方案之一。本文将介绍 RocketMQ 的底层实现原理，以及如何使用 JAVA 语言对其进行操作和实践。...

conf目录下新建一个配置文件conf/namesrv.properties，文件内容为：

创建Topic使用的命令 mqadmin updateTopic：.mqadmin updateTopicJava HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0Jav...

集群模式下，每个消费者实例会被分配到若干条队列。正因为消费者拿到了明确的队列，所以它们才能针对对应的队列做循环拉取消息的处理，以下是消费者客户端和broker通信的部分代码，可以看到通信的参数里有一个重要的参数，就是...

master和slave都可以提供读服务，但是只有master允许做写入操作，slave仅从master同步数据并不断上报自己的同步进度（slave自己的物理max offset）。