kafka(2)
文件存储机制
消息确认几种方式,说白了就是改变offset的值
1.自动提交,多久提交一次
2.手动提交
-- 手动同步提交
-- 手动异步提交
指定消费某个分区的消息
消息的消费原理
老版本的consumer offset是维护在zk上的(0.8之前)
新版本consumer是存在kafka的内部的topic里面
kafka的分区分配策略
1. range(默认)
对topic下的分区进行排序,针对consumer进行分区
2.roundrobin
group发布订阅功能,同一个分区只能由同一个消费组内的comsumer消费