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

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

>>阅读原文<<