問題タブ [debezium]
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.
json - Mongodb debezium コネクタは、データに有効な値が含まれていても、Rowkey を 0 ( zero ) および Key を 0 として設定します。
debeziumコネクタを使用してKafka接続に送信するために、mongo dbにロードしたサンプルのJsonファイルがあります。私の質問は、生のjson入力ファイルに有効なデータがあるにもかかわらず、RowKeyおよびidキー列の値が0(ゼロ)に変換されるのはなぜですか? 以下は、このエラーを生成するための手順です。
ステップ 1: サンプル json ファイルを作成する
このデータを mongodb の customerprofile コレクションにロードします
ステップ 2: mongodb debezium コネクタ構成を作成し、kafka 接続でコネクタをアクティブ化する
ステップ 3: トピック キューを確認する
以下の出力 debezium でわかるように、objectid を持つ id 列によって変換されます。
****私の質問は、JsonConvetor をキー コンバーターとして使用したため、ID 列がシリアル ID キーでどのように更新されたのでしょうか? ****
ステップ 4: トピック キューからストリームを作成する
ステップ 5: これは、ストリームが CUSTOMER_REPART からゼロ (0) を受け取る場所です。
ステップ 6: この print コマンドの出力を確認してください。ここでは、ROWKEY と ID キー列の値にゼロが表示されています。彼らはどこから来たのですか？ROWKEY および id キー列が、最初に mongodb にロードされた未加工の json ファイルの値から正しい値を表示するようにするには、どうすればよいですか?
"Male","COMMENTS":"逆クライアント サーバー アライアンス","ID":0,"LAST_NAME":"Suche","EMAIL":"csuche5@cbsnews.c {"ROWTIME":1533154567104,"ROWKEY" :"0","CLUB_STATUS":"platinum","GENDER":"Male","COMMENTS":"フェイズユニフォームソフト","ID":0,"LAST_NAME":"サットリング","EMAIL":" msuttling7@baidu. {"ROWTIME":1533154567104,"ROWKEY":"0","CLUB_STATUS":"gold","GENDER":"女性","COMMENTS":"品質重視のグローバルソフト","ID":0," LAST_NAME":"Stepney","EMAIL":"estepney8@we 段階的な統一ソフトウェア","ID":0,"LAST_NAME":"Suttling","EMAIL":"msuttling7@baidu. {"ROWTIME":1533154567104,"ROWKEY":"0","CLUB_STATUS":"gold","GENDER":"女性","COMMENTS":"品質重視のグローバルソフト","ID":0," LAST_NAME":"Stepney","EMAIL":"estepney8@we 段階的な統一ソフトウェア","ID":0,"LAST_NAME":"Suttling","EMAIL":"msuttling7@baidu. {"ROWTIME":1533154567104,"ROWKEY":"0","CLUB_STATUS":"gold","GENDER":"女性","COMMENTS":"品質重視のグローバルソフト","ID":0," LAST_NAME":"Stepney","EMAIL":"estepney8@we