Streams のコード例¶
Kafka Streams を初めて使用する場合のために、入門向けの役立つリソースを集めました。
入門用の例¶
コレクション¶
kafka-streams-examples GitHub リポジトリは、Kafka Streams DSL の使用、低レベルの Processor API、Java 8 ラムダ式、Avro データの読み書き、TopologyTestDriver による単体テストの実装、組み込み Kafka クラスターによるエンドツーエンドの統合テストのデモを行うサンプルを集めたリポジトリです。
「Kafka チュートリアル」でも多数の Kafka Streams の例が提供されています。ここでは、幅広い各種コード例を詳細な手順とともに紹介しています。
Java¶
Java 8 以降用、ラムダ式あり:
- WordCountLambdaExample
- AnomalyDetectionLambdaExample
- GlobalKTablesExample
- MapFunctionLambdaExample
- PageViewRegionLambdaExample
- UserRegionLambdaExample
- WikipediaFeedAvroLambdaExample
- ApplicationResetExample
- SessionWindowsExample
- SumLambdaExample
- TopArticlesLambdaExample
Java 7 以降用、ラムダ式なし:
Scala¶
セキュリティの例¶
対話型クエリの例¶
Confluent Platform 3.1 以降および Kafka 0.10.1 以降では、Kafka Streams DSL と Processor API で作成されたステート ストアにクエリが可能です。詳細については、「Kafka Streams の対話型クエリ」を参照してください。
エンドツーエンドのアプリケーションの例¶
これらのデモアプリケーションでは、Kafka、ZooKeeper、および Confluent Schema Registry の組み込みインスタンスを使用します。これらは統合のテストとして実装されています。
参考
Confluent Platform のすべてのサービスとともにイベントストリーミングプラットフォームにデプロイされ、他のエンドシステムと相互に接続する Kafka Streams アプリケーションのエンドツーエンドの例については、confluentinc/examples を参照してください。
Java¶
Java 8 以降用、ラムダ式あり:
- WordCountLambdaIntegrationTest
- FanoutLambdaIntegrationTest
- GenericAvroIntegrationTest
- GlobalKTablesExampleTest
- HandlingCorruptedInputRecordsIntegrationTest
- MapFunctionLambdaIntegrationTest
- MixAndMatchLambdaIntegrationTest -- DSL と Processor API を組み合わせる方法
- SpecificAvroIntegrationTest
- StateStoresInTheDSLIntegrationTest -- DSL でステートストアを使用する方法
- StreamToStreamJoinIntegrationTest
- StreamToTableJoinIntegrationTest
- TableToTableJoinIntegrationTest
- UserCountsPerRegionLambdaIntegrationTest
- ApplicationResetIntegrationTest
- EventDeduplicationLambdaIntegrationTest
- SumLambdaIntegrationTest
- TopArticlesLambdaExampleTest
Java 7 用、ラムダ式なし:
Scala¶
- StreamToTableJoinScalaIntegrationTest
- ProbabilisticCountingScalaIntegrationTest - Count-Min Sketch データ構造に基づくカスタムステートストアを実装して、入力ストリーム内のアイテムを確率的にカウントする方法のデモを示します
- GenericAvroScalaIntegrationTest
- SpecificAvroScalaIntegrationTest
- WordCountScalaIntegrationTest
イベント駆動型マイクロサービスの例¶
Java¶
イベント駆動型マイクロサービスの例では、REST インターフェイスを POST 命令と GET 命令に渡す Order Service を実装します。命令を送信すると、Kafka でイベントが作成されます。このイベントは、Fraud Service、Inventory Service、および Order Details Service という 3 つの異なる検証エンジンに受け取られます。これらのサービスは並列的に命令を検証し、各検証が成功したかどうかに基づいて PASS または FAIL を出力します。
- マイクロサービスの例のソースコード
- マイクロサービスの例のテスト
- 上のマイクロサービスの例に基づいて自分のペースで学習できる Kafka Streams チュートリアル: Confluent Platform のすべてのサービスとともにイベントストリーミングプラットフォームにデプロイされ、他のエンドシステムと相互に接続します
注釈
このウェブサイトには、Apache License v2 の条件に基づいて Apache Software Foundation で開発されたコンテンツが含まれています。