1.1、Topic:
Topic好比文件夹,一个Topic可以被分为若干个分区,一个分区就是一个提交日志。在每个分区中消息以先入先出的顺序读取,由于一个主题一般包含若干个分区,因此无法在整个主题中保证消息的顺序。分区可以分布在不同的服务器上。
kafka深入理解
1.2、Producer:

1.3、Consumer:
消费者通过检查消息的偏移量来区分已经读取过的消息,偏移量是一个不断递增的整数值,在创建消息时,kafka会把它添加到消息里。在给定的分区里每个消息的偏移量都是唯一的,Consumer把每个分区最后读取的消息偏移量保存在Zookeeper或者Kafka上,如果消费者关闭或者重启,它的读取状态不会丢失。p6

相关文章: