← 返回首页
Topic/Partition/Message扩展
发表时间:2023-10-29 14:12:36
Topic/Partition/Message扩展

Topic/Partition/Message扩展

1.Topic&Partition扩展

每个partition在存储层面是append log文件。新消息都会被直接追加到log文件的尾部,每条消息在log文件中的位置称为offset(偏移量)。越多partitions可以容纳更多的consumer,有效提升并发消费的能力。

简单一句话总结:业务类型增加需要增加topic、数据量大需要增加partition。

2.Message扩展

每条Message包含了以下三个属性:

  1. offset 对应类型:long 表示此消息在一个partition中的起始的位置。可以认为offset是partition中Message的id,自增的。
  2. MessageSize 对应类型:int32 此消息的字节大小。
  3. data 是message的具体内容。

通过下面这张图加深对Topic、Partition和Message三者之间关系的理解。