Kafka詳解五、Kafka Consumer的底層API- SimpleConsumer

the high-level consumer api

the simpleconsumer api     

第一種高度抽象的consumer api，它使用起來簡單、友善，但是對于某些特殊的需求我們可能要用到第二種更底層的api，那麼先介紹下第二種api能夠幫助我們做哪些事情

一個消息讀取多次

在一個處理過程中隻消費partition其中的一部分消息

添加事務管理機制以保證消息被處理且僅被處理一次

必須在程式中跟蹤offset值

必須找出指定topic partition中的lead broker

必須處理broker的變動

從所有活躍的broker中找出哪個是指定topic partition中的leader broker

找出指定topic partition中的所有備份broker

構造請求

發送請求查詢資料

處理leader broker變更