一、整体架构图
二、生产者数据同步架构
1、在用户拿取数据的时候,可以采用kafka的两种api:高级api和低级api
高级api:让用户使用时,很方便。大部分的操作都是已经封装好的。比如:当前消费到那个位置下。但是不够灵活【推荐】
低级api:没有进行封装,所有的操作由用户决定,如自己得保存某一个分区下的记录,你当前消费到那个位置。
三、消费数据架构
四、 Kafka 在ZooKeeper架构
高级api:让用户使用时,很方便。大部分的操作都是已经封装好的。比如:当前消费到那个位置下。但是不够灵活【推荐】
低级api:没有进行封装,所有的操作由用户决定,如自己得保存某一个分区下的记录,你当前消费到那个位置。
相关文章: