問題タブ [aws-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 接続を開始できない
スタンドアロンでも分散モードで Kafka Connect を開始しようとしていますが、続行できません
これは私のエラスティック検索シンクのプロパティです
これは私の connect-distributed.properties です
また、事前に 3 つのトピックを作成しました
これを EC2 で実行し、MSK を Kafka として使用しています。EC2 から MSK への接続を確認したところ、テレントできました
私がこれを得るエラー
質問: Kafka Connect を分散モードで実行する必要がある場合、複数の EC2/vm を使用する必要がありますか?
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 では動作しません。
いくつかの解決策を提供してください。