問題タブ [amazon-msk]
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 MSK 上の kafka connect mongo
AWS で Kafka MSK を使用しています。そのため、コンフルエントのように、必要なすべてのコネクタとネイティブのカフカ接続がありません。実際、私は kakfa mongo コネクタを使用しており、kafka mongo コネクタ jar を kafka MSK クラスターのインスタンスにプッシュする方法を見つけたいと考えています。jar がプッシュされるパスは、使用されているコネクタのプロパティで定義されている plugins.path です。
それを作る方法はありますか？
go - Sarama が Amazon MSK バージョン 2.3.1 のメッセージを生成できない
メッセージをAmazon MSKにプッシュするためにsarama golang ライブラリを使用していました。これまで、私は msk バージョン 2.2.1 を使用していましたが、コードは正常に動作していましたが、現在は msk バージョンが 2.3.1 に変更されています。現在、メッセージをトピックにプッシュできません。
エラー：
パーティション -1
オフセット -1
要求は、このブローカーに存在しないトピックまたはパーティションに対するものでした。
コード：
sarama のバージョンも maxVersion に変更しましたconfig.Version = sarama.MaxVersionが、Amazon MSK 2.3.1 では動作しません。
いくつかの解決策を提供してください。
amazon-web-services - ローカルでの amazon msk クラスターへのアクセス
vpc に amazon msk クラスター (kafka) があり、同じ vpc にあるクライアント (EC2 インスタンス) を介してアクセスできます。私の質問は.. ローカル コンピューター上のクライアントからクラスターにアクセスできますか? この構成を行うにはどうすればよいですか? vpc とサブ ネットワークのルーティング テーブルを変更しようとしましたが、まだ変更できません。