kafka在所有broker中选出一个controller，所有Partition的Leader选举都由controller决定。controller会将Leader的改变直接通过RPC的方式（比Zookeeper Qu…

1、Broker注册 Broker是分布式部署并且相互之间相互独立，但是需要有一个注册系统能够将整个集群中的Broker管理起来，此时就使用到了Zookeeper。在Zookeeper上会有一个专门用来进行Broker服…

实际项目中我们可能在创建topic时没有设置好正确的replication-factor，导致kafka集群虽然是高可用的，但是该topic在有broker宕机时，可能发生无法使用的情况。topic一旦使用又不能轻易删除…

Kafka 是一个分布式消息系统，具有高水平扩展和高吞吐量的特点。在Kafka 集群中，没有 “中心主节点” 的概念，集群中所有的节点都是对等的。 kafka Kafka 几大概念 Topic（主题） Kafka 中可将…

Kafka 架构： 以下是一般 Kafka 的架构 Kafka 架构 多节点多Broker集群 多节点多Broker集群 术语 Broker Kafka集群包含一个或多个服务器，这种服务器被称为broker，可以水平扩展…

leader 选举 和 follower 信息同步 如上图所示，kafaka集群的 broker，和 Consumer 都需要连接 Zookeeper。 Producer 直接连接 Broker。 Producer 把数…

1.前言 what？ kafka是一个分布式且基于发布/订阅的消息系统。 架构图如下： 概念： producer：生产者，负责发布消息到kafka broker：代表一台或多台服务器 topic：每条发送到kafka集群…

1. Overview 1.1 Kafka 使用Scala 语言编写, 同时没有遵从JMS 标准 1.2 特性: 持久化消息. 使用Zookeeper 来构建和管理服务器节点的集群. 节点被分为三种角色: produce…

消息生产者：producer 消息消费者：consumer 主题：即Topic，由用户定义并配置在Kafka服务端，用于建立生产者和消费者之间的订阅关系：生产者发送消息到指定Topic下，消费者从这个Topic下消费消息…