赞
踩
Kafka 中消息是以 topic
进行分类的,生产者生产消息,消费者消费消息,都是面向 topic
的
Topic 是逻辑
上的概念,而 partition 是物理
上的概念
Topic是由一个
或多个Partition Logs
(分区日志)组成,其组织结构如下图所示:
我们可以看到,每个Partition内部的消息都是有序的
Producer 生产的数据会被不断追加到 log 文件末端
,且每条数据都有自己的 offset
,消费者组中的
每个消费者,都会实时记录自己消费到了哪个 offset,以便出错恢复时,从上次的位置继续消费
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。