我看到了下面Kafka的官方声明
对于每个主题,kafka集群都维护一个分区日志
每个分区都是一个有序的、不可变的记录序列,它不断地附加到结构化提交日志中。分区中的每个记录都被分配了一个称为偏移量的顺序id号,该偏移量唯一地标识分区中的每个记录。
所以,假设我们有一个Kafka主题叫做“emprecords”,假设它现在只有一个分区,在这个分区中我们有10个偏移量,从0到9
我的问题是
每个偏移量是否只能存储一条记录?
或
每个偏移量是否有能力存储多个记录?
我看到了下面Kafka的官方声明
对于每个主题,kafka集群都维护一个分区日志
每个分区都是一个有序的、不可变的记录序列,它不断地附加到结构化提交日志中。分区中的每个记录都被分配了一个称为偏移量的顺序id号,该偏移量唯一地标识分区中的每个记录。
所以,假设我们有一个Kafka主题叫做“emprecords”,假设它现在只有一个分区,在这个分区中我们有10个偏移量,从0到9
我的问题是
每个偏移量是否只能存储一条记录?
或
每个偏移量是否有能力存储多个记录?
1条答案
按热度按时间b1payxdu1#
对于每个分区,每个偏移量只能分配给一个记录。