kafka(2)

文件存储机制

 

消息确认几种方式,说白了就是改变offset的值

1.自动提交,多久提交一次

2.手动提交

    -- 手动同步提交

    -- 手动异步提交

  指定消费某个分区的消息

 

消息的消费原理

老版本的consumer offset是维护在zk上的(0.8之前)

新版本consumer是存在kafka的内部的topic里面

 

kafka的分区分配策略

1. range(默认)

 对topic下的分区进行排序,针对consumer进行分区

2.roundrobin

group发布订阅功能,同一个分区只能由同一个消费组内的comsumer消费