1.大綱
` 可以建構kafka的java客戶段
了解kafka用戶端類型
掌握kafka用戶端的基本操作
二:用戶端類型
1.五類用戶端類型

2.kafka用戶端API類型
AdminClient:允許管理核檢測Topic,broker,以及其他的kafka對象
Producer:釋出消息到topic
Consumer:訂閱消息,并處理消息
Stream:高效的将輸入流轉換為輸出流
Connectors:從一些源系統或者應用程式中拉取資料到kafka
三:AdminClient API
1.程式
四:ProducerClient API
1.發送模式
同步發送
異步發送
異步發送回調發送
2.異步發送
效果:‘
3.同步發送
4.異步回掉
效果:
5.原理分析
KafkaProducer的構造器:
sender的原理:
圖形示意圖:
6.自定義負載均衡器
使用:
7.消費傳遞保障
kafka提供了三種傳遞保障:
最多一次
至少一次
正好一次
傳遞依賴于Producer與Consumer的共同實作
傳遞保障主要依賴于Producer
依賴于配置項: