在这个控制台数据生产者这里,再往 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 的这两个分区里。