目录 kafka server | 发布于 2017-05-16 17:22:54 | 阅读量 40 | kafka NIO
发布于 2017-05-16 17:22:54 | kafka NIO
>kafka的socket server是基于java NIO,使用`Reactor`模式开发的。socketserver主要用于处理kafka server对外提交网络请求的操作,用于检查连接数,把请求添加到请求的队列中,对KafkaApis提供操作支持. 其线程模型为: - 一个Acceptor线程接受/处理所有的新连接 - N个Processor线程,每个Processor都有自己
继续阅读
目录 kafka server | 发布于 2017-05-16 17:22:54 | 阅读量 59 | kafka server
发布于 2017-05-16 17:22:54 | kafka server
本文主要对kafka Server端Log的构造、offset的管理以及消息写入到LOG中的过程进行描述
继续阅读
目录 kafka server | 发布于 2017-05-16 17:22:54 | 阅读量 169 | kafka ISR server
发布于 2017-05-16 17:22:54 | kafka ISR server
[TOC] # 疑问 - leader是在何时更新Highwater的? - kafka-manager上出现Lag为负值是什么原因造成的? - Log中的消息被删除时,ISR之间是如何协调的? > 下面所有的讨论都是基于一个包含3个broker的kafka集群而言的 # Replica ## leader vs followers 如果将所有的topic的`replicas`设置为2(
继续阅读
目录 kafka server | 发布于 2017-05-16 17:22:54 | 阅读量 147 | kafka server
发布于 2017-05-16 17:22:54 | kafka server
Controller工作原理
对kafka Controller的工作原理进行梳理,着重对leader选举、partition状态机以及一些重要的ZK listener进行分析。
继续阅读
目录 kafka server | 发布于 2017-06-01 22:33:35 | 阅读量 208 |
发布于 2017-06-01 22:33:35 |
# GroupCoordinator > 每个kafka server在启动的时候会创建一个GroupCoordinator用于管理group以及consumer的offset fetch/commit 在创建GroupCoordinator实例时不仅需要brokerId、group以及offset config,还需要传入**replicaManager**,其作用是 ## GroupM
继续阅读