問題タブ [tombstone]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
apache-kafka - Kafka Connect トゥームストーン メッセージが InsertField 変換を適用しない
InsertField 変換は、廃棄メッセージに適用されません。
postgres 10.1 / debezium 1.2.1 バージョン / kafka 2.4.1 バージョンを使用しています
例えば。
- 構成
- 入れる
InsertField削除 (廃棄メッセージは変換を適用しません)
なぜそれが起こったのですか？バグですか？または私は間違っていますか？
cassandra - 墓石に関する Cassandra マップと列の更新
次の表があります。
時々、次のように列またはマップ エントリを更新します。
廃棄と圧縮の方法で、各クエリが古いデータをどのように処理するかを知る必要があります。
以下は私が調査/アドバイスしましたが、特に地図については情報が不足しています.
キー = 'JOE' のマップ エントリを削除するには、マップ内のそのエントリに対してのみトゥームストーンを生成します。圧縮すると、値が削除されます。
キーと値のペアをマップに挿入します。新しいエントリがあるため、古いエントリは圧縮時に削除されます。
列エントリが更新され、2 のように古い値がコンパクションで削除されます
それぞれの場合の問題は、行全体が再度書き込まれるのか、それとも新しいタイムスタンプを持つ更新された値のみが書き込まれるのかということです。
apache-kafka - 廃棄しない場合、KTable レコードはいつ期限切れになりますか?
Tメッセージの有効期限retention.msが 2 日間に設定されたトピックがあります。トピックには圧縮があります。
そのメッセージを に読み込んでKStreamからさらに に集約するKTableと、KStreamおよび/またはKTableはその 2 日間の有効期限を尊重しますか? メッセージがトピックから削除された場合、メッセージはまたはからも自動的Tに削除されますか? それとも、何らかのハウスキーピング プロセスでこれらのメッセージを破棄する必要がありますか?KStreamKTable