Kafka 文件存储机制

本文转载于 SegmentFault 社区作者：Gent  一存储文件结构 topic：可以理解为一个消息队列的名字partition：为了实现扩展性，一个非常大的 topic 可以分布到多个 broker（即服务器）上，一个 topic 可以分为多个 partition，每个 partition 是一个有序的队列segment：partition 物理上由多个 segment 组成message：每个 segment 文件中实际存储的每一条数据就是 messageoffset：每个 partition 都由一系列有序的、不可变的消息组成，这些消息被连续的追加到 partition 中，partition 中的每个消息都有一个连续的序列号叫做 offset,用于 partition 唯一标识一条消息  二Partition 分区 本例中 topic 名称为 test-topic，默认设置 partition 为 3，topic 创建成功后默认的存储位置在：/tmp/kafka-logs 下，分区分别以 topic 名称- ………………………………