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

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

相关文章:

  • 2021-08-20
  • 2021-10-23
  • 2021-07-20
  • 2021-10-17
  • 2021-07-15
  • 2021-04-26
  • 2021-11-27
  • 2021-07-15
猜你喜欢
  • 2021-05-04
  • 2021-04-19
  • 2022-02-09
  • 2021-09-20
  • 2022-01-14
  • 2022-03-10
相关资源
相似解决方案