内部の動作について説明します。フォールトトレランス、操作の簡易性が提供されるため、アプリケーション開発が簡素化されます。使用するアプリケーションの構造を示しています。アプリケーションの論理ビューです。各ストリームスレッドには複数のストリームタスクが含まれています。Kafka」を参照してください。アプリケーションのストリーム処理の計算ロジックを定義するものです。入力データがどのように出力データに変換されるかを表します。(ノード)を図示するものです。つの特殊なプロセッサーが含まれています。トピックからレコードを消費し、ダウンストリームプロセッサーに転送することで、トピックからトポロジーへの入力ストリームを生成します。シンクプロセッサーは、ダウンストリームを持たない特殊な種類のストリームプロセッサーです。トピックに送信します。通じてトポロジーを定義できます。プロセッサートポロジーは、単にストリーム処理コードの論理的な抽象化です。実行時には、この論理トポロジーがインスタンス化され、アプリケーションの内部で並列処理用に複製されます(「並列処理モデル」を参照してください)。メッセージング層では、データをパーティションに分けて格納および伝送します。パフォーマンス、フォールトトレランスが実現されます。間に密接な関係があります。