Kafka系列文章，本文主要讲述Kafka 副本机制和请求过程

第一眼看到这个问题，皮皮也是很迷惑的，谁没事会问这种问题。然而，事实上这居然是一道真实的面试题。 本来皮皮以为“皮友”只是皮着调侃一下的，既然是道面试题，那就要稍微地分析分析、说道说道了。

应大部分的小伙伴的要求，在Yarn之前先来一个kafka的小插曲，轻松愉快。 应该大部份小伙伴都清楚，用机油装箱举个例子 所以消息系统就是如上图我们所说的仓库，能在中间过程作为缓存，并且实现解耦合的作用。 引入一个场景，我们知道中国移动，x

扫描下方海报 试读 出处：https://juejin.im/post/5dcf6b6e51882510a23314f3“

这是 cxuan Kafka 系列的第二篇文章

这是一道常见的kafka面试题

有挺长一段时间没写技术文章了，正好这两天美团kafka团队有位小伙伴加了我微信，然后咨询了一个JVM crash的问题，大家对crash的问题都比较无奈，因为没有现场，信息量不多，碰到这类问题我们应该怎么去分析，我想趁这次机会和大家分享一下我针对这种问题的分析

设计Kafka架构的技术大牛，是如何优化JVM GC问题的？

是时候玩一玩kafka了！

作者：不清不慎，Java大数据开发工程师一枚，热爱研究开源技术！ 架构师社区合伙人！Kafka作为一个优秀的高性能消息中间件，广泛用于各种大数据高并发场景下，常常听一些ب

必读的Kafka最佳优化实践

作者 | Jesper Hammarbäck 编辑 | 无明 首先，我先说 Apache Kafka 是一款很酷的产品，但如果你想用它来实现事件溯源，请先慎重考虑一下。Kafka 是一个在生产者和消费者之间传递消息的绝

PerfMa作为一家新型的技术驱动型公司，技术是我们的命根子，企业公众号的第一篇文章也希望特别一点，给大家来一篇大大的干货，我们后续也会在我们的公众号里给大家源源不断地奉上干货，大家可以关注一下我们公众号

阿里大牛实战归纳——Kafka架构原理

Kafka在0.8以前的版本中，并不提供High Availablity机制，一旦一个或多个Broker宕机，则宕机期间其上所有Partition都无法继续提供服务。若该Broker永远不能再恢复，亦或磁盘故障，则其上数据将丢失。

Kafka的网络层模型使用NIO技术处理网络通信。SocketServer通过Acceptor和Processor线程处理请求和连接。Acceptor负责监听和接受新连接，并分配给Processor处理。Processor有三个主要功能：处理完成的请求的响应、调用selector.poll()完成数据的接收和发送、处理已完成的接收操作。具体的流程是根据请求类型操作当前连接的nio selector，暂时删除读事件监听、添加写事件或关闭连接。同时，通过selector.completedReceives.asScala.foreach来处理已完成的接收操作。RequestChannel类在core/src/main/scala/kafka/network/RequestChannel.scala文件中保存所有的完整请求和需要发送的响应，由RequestHandler周期性获取请求并处理响应。ConnectionQuotas类则负责监控网络连接。