天天看點

kafka的用戶端操作,admin與producer

1.大綱

`  可以建構kafka的java客戶段

  了解kafka用戶端類型

  掌握kafka用戶端的基本操作

二:用戶端類型

1.五類用戶端類型

  

kafka的用戶端操作,admin與producer

2.kafka用戶端API類型

  AdminClient:允許管理核檢測Topic,broker,以及其他的kafka對象

  Producer:釋出消息到topic

  Consumer:訂閱消息,并處理消息

  Stream:高效的将輸入流轉換為輸出流

  Connectors:從一些源系統或者應用程式中拉取資料到kafka

三:AdminClient API

1.程式

四:ProducerClient API

 1.發送模式

  同步發送

  異步發送

  異步發送回調發送

2.異步發送

  效果:‘

kafka的用戶端操作,admin與producer

3.同步發送

4.異步回掉

  效果:

kafka的用戶端操作,admin與producer

5.原理分析

  KafkaProducer的構造器:

  sender的原理:

  圖形示意圖:

kafka的用戶端操作,admin與producer
kafka的用戶端操作,admin與producer

6.自定義負載均衡器

  使用:

7.消費傳遞保障

  kafka提供了三種傳遞保障:

    最多一次

    至少一次

    正好一次

  傳遞依賴于Producer與Consumer的共同實作

  傳遞保障主要依賴于Producer

  依賴于配置項: