kafka工具 offset explore

    image.png

    创建副本的单位是topic的分区，每个分区有1个leader和0到多个follower，我们把多个replica分为Lerder replica和follower replica。

    kafka不是完全同步，也不是完全异步，是一种特殊的ISR（In Sync Replica）
    1.leader会维持一个与其保持同步的replica集合，该集合就是ISR，每一个partition都有一个ISR，它时有leader动态维护。
    2.我们要保证kafka不丢失message，就要保证ISR这组集合存活（至少有一个存活），并且消息commit成功。

    基本数据类型：（Kafka是基于Scala语言实现的，类型也是Scala中的数据类型）
    定长数据类型：int8,int16,int32和int64，对应到Java中就是byte, short, int和long。
    变长数据类型：bytes和string。变长的数据类型由两部分组成，分别是一个有符号整数N(表示内容的长度)和N个字节的内容。其中，N为-1表示内容为null。bytes的长度由int32表示，string的长度由int16表示。
    数组：数组由两部分组成，分别是一个由int32类型的数字表示的数组长度N和N个元素。

    https://www.cnblogs.com/zzzzrrrr/p/13197390.html