flafでkafkaを使用する理由

Question

現在、私はFlinkでストリーム処理のドメインを発見しています。しかし、これまでに読んだ専門記事のほとんどは、フリンクとカフカについて語っています。しかし、私はこのデュオがなぜそんなに論理的であるかを明確に説明していないし、カフカがフリンクができないことを説明したり、その逆を説明したりもしなかった。 FLINKはPROCESS_CONTINUOUSLY readCsvFileとカフカとのこの側面、 でサポートできることができない - - カフカは、ストリームの集約を行うことができますが、それはカフカに比べて（わからない）限らようだ：

は、これまでのところ私は、次を発見しました。

これらのシステムでこれまでに持っていた知識や経験を追加することをためらわずにご利用ください。事前にどうもありがとうございました。

Answer 1

最初の視点での違いは明らかではないことは事実です。

Apache Kafkaは、リアルタイム情報を処理して迅速に消費者にルーティングするソリューションです。つまり、メッセージブローカーです。

Apache Flinkは、ストリーム処理フレームワークです。これには、メモリー内の分散コンピューティングが含まれます。

つまり、基本的にKafkaはメッセージルーターの役割を持ち、Apache Flinkはデータを処理します。

以下の例のスキーマからわかるように、Kafkaは異種ソースからのメッセージを公開することができ、Apache Flinkはウィンドウ機能やリダクション機能を適用してこれらのデータを処理します。

あなたはカフカのドキュメントに見れば、彼らは（元カフカの一部ではない）カフカストリームと呼ばれるカフカの上に新しい機能を導入しました。これは、Apache Flinkと同様にデータを処理する能力を持つストリーム処理フレームワークです。