天天看点

kafka的客户端操作,consumer API

一:Consumer API

1.自动提交程序

  这种不建议在实际中使用

  

2.手动提交offset

  如果事务失败了,么有提交,下次还能继续获取到数据

3.ConsumerGroup

  单个分区的消息只能有ConsumerGroup中的某个Consumer消费

  Consumer从partition中的消费是顺序,默认从头开始

  单个ConsumerGroup会消费所有partition中的消息

4.特性

kafka的客户端操作,consumer API

5.按照patition维度进行处理

6.只消费某个partition

二:Consumer API的多线程处理

 1.第一种方式

kafka的客户端操作,consumer API

2.程序

3.第二种方式

  这种方式,是没有办法提交offset的,只是为了快速消费数据

kafka的客户端操作,consumer API

4.程序

三:一些其他的特性

1.手动控制offset

2.限流