kafka session.timeout.ms 是指消费一条数据的时间?_干货 | Kafka 内核知识梳理，附思维导图...

前面我们已经分享过几篇Kafka的文章，最近简单梳理了下Kafka内核相关的知识，涵盖了Kafka架构总结，副本机制，控制器，高水位机制，日志或消息存储，消息发送与消费机制等方面知识。文末含对应的Kafka内核思维导图，供参考。

1、 架构总结

1）Kafka实际上也是一个主从架构，有一个Controller角色即控制器，协调管理整个集群；

2）有几个Kafka术语肯定是不陌生的：broker，topic，partition，segment，生产者producer，消费者consumer；

2、消息发送机制

1）序列化器：序列化消息对象转成字节数组，然后通过网络传输。2）分区器：计算消息发往的具体分区；如果显示指定了partition，便不会走分区器。

3）消息缓冲池：客户端的消息缓冲池，默认大小32M，见参数buffer.memory。

4）批量发送：缓冲池中消息会按batch分批次发送，默认批次大小16KB，见参数batch.size。

3、副本机制

1）分区副本默认1，见参数default.replication.factor。

2）副本作用（并不提供读写分离）

• 实现冗余，提高消息可靠性；
• 实现高可用，参与leader选举，在leader不可用时提高可用性。</