238
《KAFKA官方文檔》5.2 APIs
2. APIs
Kafka包含四種核心的API:
- Producer API支持應用將數據流發送到Kafka集群的主題。
- Consumer API支持應用從Kafka集群的主題中讀取數據流。
- Streams API支持數據流從輸入主題轉化到輸出主題。
- Connect API支持實現持續地從一些源係統或應用劃入Kafka或者從Kafka推入一些源係統或應用的接口。
Kafka通過獨立於語言的協議公開其所有功能，該協議具有可用於諸多編程語言的客戶端。但是，隻有Java客戶端作為主Kafka項目的一部分進行維護，其他客戶端隻是獨立的開源項目。可用的非Java客戶端的列表請 點擊這裏。
2.1 Producer API
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>
2.2 Consumer API
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>
2.3 Streams API
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>
2.4 Connect API
Connect API 支持實現持續地將數據從一些源係統或應用劃入Kafka或者從Kafka推入一些源係統或應用的接口。
Connect的大多數使用者不需要馬上使用此API，但是它們可以使用預先建立的連接器，而無需編寫任何代碼。 有關使用Connect的其他可用文檔 請點擊這裏.
那些想要實現定製連接器的人可以參考 這裏的文檔.
2.5 Legacy APIs
Kafka同樣也包含了一些有限並且古老的producer以及consumer api。這些舊的Scala API已被棄用，僅僅出於兼容的目的而存在。 有關他們的信息可以在
這裏找到。
最後更新：2017-05-18 20:36:33