kafka 1.0中国語ドキュメント(二)--APIS

1 Producer API

2 Consumer API

3 Streams API

4 Connect API

5 AdminClient API

6従来のAPI

kafkaは5つのコアapis:1を含む.Producer APIは、アプリケーションがKafkaクラスタ内のトピックにデータストリームを送信することを可能にする.2.Consumer APIは、アプリケーションがKafkaクラスタ内のトピックからデータストリームを読み込むことを可能にする.3.Streams APIでは、入力トピックのデータストリームを出力トピックに変換できます.4.Connect APIは、いくつかのソースシステムまたはアプリケーションからKafkaのコネクタを継続的に入力するか、またはKafkaからいくつかの受信機システムまたはアプリケーションを入力することを可能にする.5.AdminClient APIでは、トピック、エージェント、およびその他のKafkaオブジェクトの管理およびチェックを許可します.
Kafkaは言語に依存しないプロトコルによってすべての機能を開示し,クライアントは多くのプログラミング言語を使用することができる.ただし,Javaクライアントのみが主なKafkaプロジェクトの一部としてメンテナンスされ,その他は独立したオープンソースプロジェクトとして提供される.
2.1 Producer API
Producer APIは、アプリケーションがKafkaクラスタ内のトピックにデータストリームを送信することを可能にする.プロバイダの使用方法の例をjavadocで示します.
生産者を使用するには、次のmaven依存を使用します.

<dependency>
    <groupId>org.apache.kafkagroupId>
    <artifactId>kafka-clientsartifactId>
    <version>1.0.0version>
dependency>

2.2 Consumer API
Consumer APIは、アプリケーションがKafkaクラスタ内のトピックからデータストリームを読み込むことを可能にする.消費者の使用方法を示す例はjavadocで示されている.
ユーザーを使用するには、次のmaven依存を使用します.

<dependency>
    <groupId>org.apache.kafkagroupId>
    <artifactId>kafka-clientsartifactId>
    <version>1.0.0version>
dependency>

2.3 Streams API
Streams APIでは、入力トピックのデータストリームを出力トピックに変換できます.このライブラリの使用方法の例をjavadocで示します.
Streams APIの使用に関する他のドキュメントは、ここで参照できます.
Kafka Streamsを使用するには、次のmaven依存項目を使用します.

<dependency>
    <groupId>org.apache.kafkagroupId>
    <artifactId>kafka-streamsartifactId>
    <version>1.0.0version>
dependency>

2.4 Connect API
Connect APIは、いくつかのソースデータシステムからKafkaのコネクタを引き込むか、またはKafkaからいくつかの受信機データシステムに押し込むことを可能にする.Connectの多くのユーザーは、このAPIを直接使用する必要はありませんが、コードを記述する必要がなく、事前に確立されたコネクタを使用することができます.Connectの使用方法の詳細については、こちらをクリックしてください.
カスタムコネクタを実装したい人はjavadocを見ることができます.
2.5 AdminClient API
AdminClient APIは、トピック、エージェント、acl、その他のKafkaオブジェクトの管理とチェックをサポートします.AdminClient APIを使用するには、次のMaven依存項目を追加します.

<dependency>
    <groupId>org.apache.kafkagroupId>
    <artifactId>kafka-clientsartifactId>
    <version>1.0.0version>
dependency>

AdminClient APIの詳細についてはjavadocを参照してください.
2.6従来のAPI
kafkaはまた、より限られた従来の生産者および消費者APIを含む.これらの古いScala APIは破棄され、互換性の目的でのみ使用できます.彼らに関する情報はここで見つけることができます.