第1章 Streams for Apache Kafka の概要

AMQ Streams は、Apache Kafka プロジェクトをベースとした、スケーラビリティの高い分散型の高性能データストリーミングをサポートします。

主なコンポーネントは以下で構成されます。

Kafka Broker: 生成クライアントから消費側のクライアントにレコードを配信するメッセージングブローカー
Kafka Streams API: ストリームプロセッサー アプリケーションを作成するための API
プロデューサーおよびコンシューマー API: Kafka ブローカーとの間でメッセージを生成および消費するための Java ベースの API
Kafka Bridge: Streams for Apache Kafka Bridge は、HTTP ベースのクライアントと Kafka クラスターとの対話を可能にする RESTful インターフェイスを提供します。
Kafka Connect: Connector プラグインを使用して、Kafka ブローカーと他のシステム間でデータをストリーミングするツールキット
Kafka MirrorMaker: データセンター内またはデータセンター全体の 2 つの Kafka クラスター間でデータをレプリケーションする。
Kafka Exporter: 監視用に Kafka メトリクスデータの抽出に使用されるエクスポーター

Kafka ブローカーのクラスターは、これらのすべてのコンポーネントを接続するハブです。

図1.1 Streams for Apache Kafka のアーキテクチャー

1.1. Kafka Bridge を使用した Kafka クラスターへの接続

Streams for Apache Kafka Bridge API を使用すると、コンシューマーを作成および管理し、ネイティブの Kafka プロトコルではなく HTTP を介してレコードを送受信できます。

Kafka Bridge を設定する場合、Kafka クラスターへの HTTP アクセスを設定します。その後、Kafka Bridge を使用して、クラスターからのメッセージを生成および消費したり、REST インターフェイスを介して他の操作を実行することができます。

関連情報

トップに戻る