(一)、消費者連接器如何創建數據流=====》消費者初始化

以0.10.2.1版本爲主分析kafka源碼。如有分析不當之處,還望留言指出,相互學習,謝謝!。 1、目前kafak的消費者連接器只有一種基於zookeeper的     老版本中的消費者只有兩個方法:根據配置文件創建消費者連接器   創建基於java的連接器,其實還是zookeeper的 消費者連接器內部通過調用consume方法創建數據流。核心主要放在consume方法內部。 consume方
相關文章
相關標籤/搜索