在Kafka中向topic发送消息者称为Producer,从topic获取数据者称为Consumer,Consumer被定义到一个Consumer Group中,整个Kafka集群通过Zookeeper进行协调
Kafka集群由多个broker实例组成,消息按照topic进行分类存储,每个topic被分为多个分区,每个分区又存在多个副本,保证数据对可用性
Kafka 每个partition副本为一个目录,partition以segment为单位存储数据,kafka为每个segment创建两个索引,index文件以偏移量为索引,timeindex以写入时间戳为索引。这种索引可以在logn的时间复杂度快速定位到segment中的数据