この Flink CEPの例を調べようとしています。この例では、データを生成および消費し、データにパターン マッチングを適用する単一のアプリケーション (一種のストリーミング アプリケーション) が作成されていることがわかります。彼らはその間にストリーミングレイヤーを入れていません（Kafkaのように）。今のところ、この目的には単一のアプリケーションで十分であり、非常に最適化されています。これで、Kafka を使用する場合、2 つのアプリケーションが必要になることがわかりました。1 つは Kafka トピックにデータを取り込むためのもので、もう 1 つは Kafka トピックからデータを消費するためのものです。答えられない質問がいくつかあります::
この例でストリーミング レイヤー (Kafka など) を使用していないのはなぜですか??
いつ、どこでストリーミングが必要ですか??
Flink CEP の例を参照すると、ストリーミング レイヤー (Kafka/Kinesis など) がどこでどのように機能するかを知りたいですか??
Kafka/Kinesis のようなストリーミング レイヤーが間に入る場合の利点/欠点は何ですか??