1.Kafka的基本介紹
?
1)什么是消息系統(tǒng)?
?
2)消息隊列的分類
?
3)kafka的基本架構(gòu)和概念
?
4)ZooKeeper簡介和安裝
2.Kafka的原理解析
?
1)Kafka在ZK上的存儲結(jié)構(gòu)
?
2)Producer的處理邏輯
?
3)Consumer的處理邏輯
?
4)Broker的處理邏輯
3.Kafka安裝和部署
?
1)關(guān)閉服務(wù)
?
2)下載軟件
?
3)拷貝文件
?
4)重啟服務(wù)
?
5)測試功能是否能用
4.Kafka的Java應(yīng)用開發(fā)
?
1)Producer端的實現(xiàn)
?
2)Consumer端的實現(xiàn)
?
3)程序執(zhí)行演示
5.Kafka與Hadoop集成
?
1)Hadoop簡介和配置
?
2)集成Kafka和Hadoop
?
3)例子演示
6、案例講解:Kafka與Flume實時統(tǒng)計指定目錄文件數(shù)