《KAFKA官方文件》5.2 APIs
阿新 • • 發佈:2018-12-22
原文連結 譯者:flystarfly
Kafka包含四種核心的API:
- Producer API支援應用將資料流傳送到Kafka叢集的主題。
- Consumer API支援應用從Kafka叢集的主題中讀取資料流。
- Streams API支援資料流從輸入主題轉化到輸出主題。
- Connect API支援實現持續地從一些源系統或應用劃入Kafka或者從Kafka推入一些源系統或應用的介面。
Kafka通過獨立於語言的協議公開其所有功能,該協議具有可用於諸多程式語言的客戶端。但是,只有Java客戶端作為主Kafka專案的一部分進行維護,其他客戶端只是獨立的開源專案。可用的非Java客戶端的列表請 點選這裡。
Producer API支援應用將資料流傳送到Kafka叢集的主題。
這裡提供瞭如何使用Producer API的文件。
要使用Kafka Producer API,可以使用以下maven依賴:
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.10.2.0</version> </dependency>
Consumer API 支援應用從Kafka叢集的主題中讀取資料流。
這裡提供瞭如何使用Consumer API的文件。
要使用Kafka Consumer API,可以使用以下maven依賴:
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.10.2.0</version> </dependency>
Streams API 支援資料流從輸入主題轉化到輸出主題。
這裡提供瞭如何使用Streams API的文件。
有關使用Streams API的其他可用文件 請點選這裡.
要使用Kafka Streams API,可以使用以下maven依賴:
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> <version>0.10.2.0</version> </dependency>
Connect API 支援實現持續地將資料從一些源系統或應用劃入Kafka或者從Kafka推入一些源系統或應用的介面。
Connect的大多數使用者不需要馬上使用此API,但是它們可以使用預先建立的聯結器,而無需編寫任何程式碼。 有關使用Connect的其他可用文件 請點選這裡.
那些想要實現定製聯結器的人可以參考 這裡的文件.
Kafka同樣也包含了一些有限並且古老的producer以及consumer api。這些舊的Scala API已被棄用,僅僅出於相容的目的而存在。 有關他們的資訊可以在
這裡找到。