用户登录

在这个控制台数据生产者这里,再往 demo 这个 topic 里发布一条消息。然后到控制中心观察一下。 新的消息仍然属于 demo 这个 topic , 消息所在的 partion 的编号是 0, 消息的 offset 也是 0。

上一次消息的 offset 也是 0 ,这是因为这条消息属于编号是 1 的这个 partition。 刚才我们添加的这条消息,分区的编号是 0 。 这个叫 demo 的 topic 有两个分区,分区的编号分别是是 0 还有 1 。

这样我们往这个 topic 里发布消息的时候,这些消息会分别放到不同的分区里。每一个分区的消息的 offset 都是从 0 开始的。

回到终端,再发布一条消息,然后再回到控制中心观察一下。 新发布的这条消息的分区编号是 1, 它的 offset 是 1 , 因为在编号是 1 的这个分区里,上一条消息的 offset 是 0,所以在这个分区里的下一条消息的 offset 的值就会是 1。

在终端,再发布一条消息,然后回到控制中心观察一下这条消息的 offset 。 你会发现消息的 offset 是 1,所属的分区的编号是 0, 在这个分区里的上一条消息的编号是 0 ,所以在这个分区里新发布的这个消息的 offset 就会是 1。

用这个 console producer 再发布两条消息, 再观察一下消息的 offset 。 这两条消息的 offset 都是 2 ,分布在编号是 0 还有 1 的这两个分区里。

Offset:消息在分区里的编号《 Kafka:关键概念 》

统计

15260
分钟
0
你学会了
0%
完成

社会化网络

关于

微信订阅号

扫描微信二维码关注宁皓网,每天进步一点