存储组件

  • KafkaApis : Kafka 应用接口组件,当 Kafka Producer 向 Kafka Broker 发送数据请求后, Kafka Broker 接收请求,会使用 Apis 组件进行请求类型的判断,然后选择相应的方法进行处理。
  • ReplicaManager : 副本管理器组件,用于提供主题副本的相关功能,在数据的存储前进行 ACK 校验和事务检查,并提供数据请求的响应处理
  • Partition : 分区对象,主要包含分区状态变换的监控,分区上下线的处理等功能,在数据存储是主要用于对分区副本数量的相关校验,并提供追加数据的功能
  • UnifiedLog : 同一日志管理组件,用于管理数据日志文件的新增,删除等功能,并提供数据日志文件偏移量的相关处理。
  • LocalLog : 本地日志组件,管理整个分区副本的数据日志文件。假设当前主题分区中有 3 个日志文件,那么 3 个文件都会在组件中进行管理和操作。
  • LogSegment : 文件段组件,对应具体的某一个数据日志文件,假设当前主题分区中有 3 个日志文件,那么 3 个文件每一个都会对应一个 LogSegment 组件,并打开文件的数据管道 FileChannel。数据存储时,就是采用组件中的 FileChannel 实现日志数据的追加。
  • LogConfig: 日志配置对象,常用的数据存储配置。