問題タブ [confluent-cloud]
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 res api 応答でジャンク値を取得する
コンフルエントなクラウド上のkafkaインスタンスからの場合、Rest APIを使用してトピックを取得しています
以下のcurlコマンドを使用しています
しかし、私はジャンク値を取得していop.txtます
これに対する解決策はありますか？
mongodb - MongoDB Sink Connector を使用して、別の主キーで既存のドキュメントを更新する
pgsql と MongoDB の間でデータの同期を維持する Confluent Cloud 経由で MongoDB Sink Connector をセットアップしようとしています。
id以下の構成が(int) フィールド (_id - objectId ではない)に基づいて既存のドキュメントを更新することを期待していますが、消費時に MongoDB に新しいドキュメントを作成するだけです。pg からのドキュメントには _id フィールドが含まれないため、pgsql の主キー (id) でルックアップを行う必要があります。
これが期待どおりに機能しない理由はありますか?
amazon-web-services - sarama consumergroup を AWS でホストされているコンフルエントなクラウド kafka に接続します。いいえ
これは、AWS サーバーでホストされている Confluent Kafka クラスターに接続しようとする最初の試みですが、Amazon マネージド ストリーミング サービスを使用していません。
このコードを使用して、古い自己ホスト型クラスターに問題なく接続できました (Config.Net.SASL セットアップを除く)。
何が間違っているのかわかりません。
接続すると、次のエラーが発生します。
これは私のコードです: