两者之间唯一存在的联系恐怕就是它们都和发布/订阅范式有关了吧。MQTT 是基于发布/订阅范式的消息协议，而 Apache Kafka 的生产、消费的流程也是属于发布/订阅范式的。那么如果我们基于 MQTT 协议去实现一个消息 broker ，是否这个 MQTT broker是否能和 Kafka 作用等价

先看单机Kafka部署：Windows下部署 Kafka（单机） 1、先部署ZooKeeper集群，参考：Windows下部署 ZooKeeper（集群） 2、分别修改 Kafka config 目录下的 server.properties 配置文件： node-1： #唯一标识 broker.id=0 #监听端口 port=9092 host.name=127.0.0.1 #消息最大大小 mes

一、kafka拓扑结构： 二、Kafka架构图： 三、Kafka的特点 1、同时为分布和订阅提供高吞吐量。 2、可进行持久化操作，将消息持久化到到磁盘，以日志的形式存储，因此可用于批量消费，例如ETL，以及实时应用程序。 通过将数据持久化到硬盘以及replication防止数据丢失。 3、分布式系统，易于向外拓展。所有的Producer、broker和consumer都会有多个，均为分布式。无需停

1、安装 JDK 并配置Java环境 2、安装ZooKeeper         Kafka的运行依赖于ZooKeeper，所以在运行Kafka之前我们需要先安装并运行ZooKeeper。         Kafka使用ZooKeeper作

Kafka与ZooKeeper：     一个典型的Kafka集群中包含若干Produce，若干broker（一般broker数量越多，集群吞吐率越高），若干Consumer Group，以及一个Zookeeper集群。Kafka通过Zookeeper管理集群配置，选举leader，以及在Consumer Group发生变化时进行rebalance。Producer使用push