一:Consumer API
1.自动提交程序
这种不建议在实际中使用
2.手动提交offset
如果事务失败了,么有提交,下次还能继续获取到数据
3.ConsumerGroup
单个分区的消息只能有ConsumerGroup中的某个Consumer消费
Consumer从partition中的消费是顺序,默认从头开始
单个ConsumerGroup会消费所有partition中的消息
4.特性

5.按照patition维度进行处理
6.只消费某个partition
二:Consumer API的多线程处理
1.第一种方式

2.程序
3.第二种方式
这种方式,是没有办法提交offset的,只是为了快速消费数据
4.程序
三:一些其他的特性
1.手动控制offset
2.限流