Streams のコード例

Kafka Streams を初めて使用する場合のために、入門向けの役立つリソースを集めました。

入門用の例

コレクション

kafka-streams-examples GitHub リポジトリは、Kafka Streams DSL の使用、低レベルの Processor API、Java 8 ラムダ式、Avro データの読み書き、TopologyTestDriver による単体テストの実装、組み込み Kafka クラスターによるエンドツーエンドの統合テストのデモを行うサンプルを集めたリポジトリです。

Kafka チュートリアル」でも多数の Kafka Streams の例が提供されています。ここでは、幅広い各種コード例を詳細な手順とともに紹介しています。

セキュリティの例

Java プログラミング言語

Java 7 用、ラムダ式なし:

対話型クエリの例

Confluent Platform 3.1 以降および Kafka 0.10.1 以降では、Kafka Streams DSLProcessor API で作成されたステート ストアにクエリが可能です。詳細については、「Kafka Streams の対話型クエリ」を参照してください。

Java

Java 8 以降用、ラムダ式あり:

エンドツーエンドのアプリケーションの例

これらのデモアプリケーションでは、Kafka、ZooKeeper、および Confluent Schema Registry の組み込みインスタンスを使用します。これらは統合のテストとして実装されています。

参考

Confluent Platform のすべてのサービスとともにイベントストリーミングプラットフォームにデプロイされ、他のエンドシステムと相互に接続する Kafka Streams アプリケーションのエンドツーエンドの例については、confluentinc/examples を参照してください。

Scala

イベント駆動型マイクロサービスの例

Java

イベント駆動型マイクロサービスの例では、REST インターフェイスを POST 命令と GET 命令に渡す Order Service を実装します。命令を送信すると、Kafka でイベントが作成されます。このイベントは、Fraud Service、Inventory Service、および Order Details Service という 3 つの異なる検証エンジンに受け取られます。これらのサービスは並列的に命令を検証し、各検証が成功したかどうかに基づいて PASS または FAIL を出力します。

../_images/microservices-demo.png

注釈

このウェブサイトには、Apache License v2 の条件に基づいて Apache Software Foundation で開発されたコンテンツが含まれています。