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