kafka总结
环境
kafka 2.0
概念
- Partition(分区): 一个Topic可以有一个或多个Partition， 一个Partion内消息有序
- Replica(副本): 一个分区可以有多个副本(一个消息有多份);
- AR(Assigned Replicas) 分区中的所有副本统称为AR;
- ISR(In-Sync Replicas): 所有与leader副本保持一定同步(可通过参数配置)的副本(包括leader副本);
-
OSR(Out-of-Sync Replicas): 与leader副本同步滞后过多的副本(不包括leader副本);
所以AR = ISR + OSR - HW(High Watermark, 高水位): 标识了一个特定的消息偏移量(offset), 消息者只能摘取到HW之前的消息;
-
LEO(Log End Offset): 标识当前日志中下一条待写入消息的offset
（未完待续）