Kafka-ビューは継続的に更新されるキャッシュの形式のように動作しますか?どうやって

チャンダングプタ

「ビューは継続的に更新されるキャッシュの形式のように動作します」?

これは、Kafkaをリッスンするストリームコンシューマーアプリケーションがビューまたはキャッシュを更新し続け、キャッシュされたデータがkafkaサーバーではなくクライアントマシンに保存されることを意味しますか?

ヴァルボン

Kafka それ自体には「ビュー」の概念はありません。

Kafka Streamsビューまたはキャッシュとして機能できるKTableまたはを構築できますGlobalKTable

これは、Kafkaをリッスンするストリームコンシューマーアプリケーションがビューまたはキャッシュを更新し続けることを意味しますか?

はい、Kafkaトピックからアプリケーションが消費したイベントに基づいて、キャッシュまたはビューの維持を担当するのはコンシューマーアプリケーションです。(そして、Kafka Streamアプリケーションはコンシューマーアプリケーションと見なすことができます。)

キャッシュされたデータはkafkaサーバーではなくクライアントマシンに保存されますか?

コンシューマーアプリケーションは、現在の状態をどこかに保存する必要があります。

ただし、データはKafkaトピックにも残ります。

この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。

侵害の場合は、連絡してください[email protected]

編集
0

コメントを追加

0

関連記事

KafkaをFiFoキューのように動作するように構成するにはどうすればよいですか?

Kafkaプロデューサーはネットワークパーティション中にどのように動作しますか?

特定のコンシューマーがJavaを使用してKafka0.9.0.xに接続されているかどうかを確認する方法は?

相互接続されたエンティティ スキーマを RDMS やグラフなどのデータベースによってイベントの形式で使用できるように Kafka トピックを構成する方法

Kafkaクラスターで使用される増分フェッチセッションキャッシュスロットの実際の数を確認するにはどうすればよいですか?

プロデューサーがダウンした場合、Kafkaコンシューマーはどのように動作しますか。プロデューサーがダウンした間隔でデータはどうなりますか

各バッチでSpring Kafkaコンシューマーによって消費されるメッセージの数を増やす方法は?

librdkafkaプロデューサーはKafkaの新しいトピックパーティションについてどのように学習しますか

Kafkaを継続的に消費し、マルチプロセッシングを使用して特定の間隔でキューを更新します

akkaストリームを使用して既存のコンシューマーグループに新しいコンシューマーを作成しているときに、kafkaトピックを終了するにはどうすればよいですか?

Kafkaで複数のコンシューマーを使用するにはどうすればよいですか?

Kafkaはパーティション内のメッセージをどのように内部的に順序付けますか?プロデューサーから受け取ったままの状態で保管していますか?

間違った形式のメッセージを無視するようにspring-kafkaを構成するにはどうすればよいですか?

マルチスレッド Kafka プロデューサーはどのように機能しますか?

コンシューマーを追加すると、kafka処理のスケーラビリティがどのように向上しますか

Kafkaは、他のコンシューマーよりも実行速度が遅いコンシューマーをどのように処理しますか?

特定のトピックからKafkaコンシューマーグループを削除するにはどうすればよいですか?

kafkaは、停止中に送信されたメッセージをどのように処理しますか?

サポートされるQPSに基づいてKafkaコンシューマーを調整するにはどうすればよいですか?

Kafkaプロデューサーの例のNoClassDefFoundErrorを修正するにはどうすればよいですか?

Kafkaプロデューサーの例のNoClassDefFoundErrorを修正するにはどうすればよいですか?

同じグループのkafkaコンシューマーは、どのようにメッセージを共有しますか?

Kafka / Kafkaストリームのデータを更新するにはどうすればよいですか?

kafka-nodeモジュールを使用してEventHubのKafkaに接続する方法はありますか?

Kafka:メニューまたはデシジョンツリーを介して、ユーザーが複数のオプションを選択して調整するにはどうすればよいですか?

同時実行性が1以上に設定されている場合、特定のkafkaコンシューマースレッドを一時停止するにはどうすればよいですか?

Flumeを使用して、トピック、kafkaからkafkaをどのようにシンクしますか?

Apache Kafkaのパーティションにデータはどのように追加されますか?

Apache Kafka オフセットはどのように生成されますか?

TOP 一覧

  1. 1

    グラフからテーブルに条件付き書式を適用するにはどうすればよいですか?

  2. 2

    ソートされた検索、ターゲット値未満の数をカウント

  3. 3

    Unity:未知のスクリプトをGameObject(カスタムエディター)に動的にアタッチする方法

  4. 4

    セレンのモデルダイアログからテキストを抽出するにはどうすればよいですか?

  5. 5

    Ansibleで複数行のシェルスクリプトを実行する方法

  6. 6

    Reactでclsxを使用する方法

  7. 7

    tkinterウィンドウを閉じてもPythonプログラムが終了しない

  8. 8

    Windows 10 Pro 1709を1803、1809、または1903に更新しますか?

  9. 9

    Pythonを使用して同じ列の同じ値の間の時差を取得する方法

  10. 10

    PowerShellの分割ファイルへのヘッダーの追加

  11. 11

    Chromeウェブアプリのウェブビューの高さの問題

  12. 12

    BLOBストレージからデータを読み取り、Azure関数アプリを使用してデータにアクセスする方法

  13. 13

    Crashlytics:コンパイラー生成とはどういう意味ですか?

  14. 14

    GoDaddyでのCKEditorとKCfinderの画像プレビュー

  15. 15

    Windows 10の起動時間:以前は20秒でしたが、現在は6〜8倍になっています

  16. 16

    MLでのデータ前処理の背後にある直感

  17. 17

    モーダルダイアログを自動的に閉じる-サーバーコードが完了したら、Googleスプレッドシートのダイアログを閉じます

  18. 18

    reCAPTCHA-エラーコード:ユーザーの応答を検証するときの「missing-input-response」、「missing-input-secret」(POSTの詳細がない)

  19. 19

    STSでループプロセス「クラスパス通知の送信」のループを停止する方法

  20. 20

    ファイル内の2つのマーカー間のテキストを、別のファイルのテキストのセクションに置き換えるにはどうすればよいですか?

  21. 21

    ネットワークグラフで、ネットワークコンポーネントにカーソルを合わせたときに、それらを強調表示するにはどうすればよいですか?

ホットタグ

アーカイブ