Kafka不仅是消息队列而是一个分布式消息处理平台
然后，主题还可以细分为多个分区一个分区只能属于单个主题，并且同一主题下的各个分区包含的消息数据也是不同的，分区在存储层面可以看作一个可追加的日志（Log）文件，消息被追加到分区分区日志文件的时候都会分配一个特点的偏移量（offset）。它标识当前日志文件中下一条待写入消息的offset,如下图所示，offset为9的位置即为当前日志文件的LEO,LEO的大小相当于当前日志分区中最后一条消息的offset加1。高水位，它标识了一个特定的消息偏移量（offset）,消费者只能拉取到这个offset之前的消息。
复制链接