1. 程式人生 > >《KAFKA官方文件》5.2 APIs

《KAFKA官方文件》5.2 APIs

原文連結 譯者:flystarfly

Kafka包含四種核心的API:

  1. Producer API支援應用將資料流傳送到Kafka叢集的主題。
  2. Consumer API支援應用從Kafka叢集的主題中讀取資料流。
  3. Streams API支援資料流從輸入主題轉化到輸出主題。
  4. 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已被棄用,僅僅出於相容的目的而存在。 有關他們的資訊可以在
這裡
找到。