天天看點

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.限流