問題タブ [message-hub]
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.
ibm-cloud - メッセージ ハブのサンプル コードを実行すると FileNotFoundException が発生する
https://github.com/ibm-messaging/message-hub-samplesから Kafka ネイティブ Message Hub サンプル コードを実行すると、次の例外が発生します。
不足しているファイルは何ですか?
message-hub - Message Hub 用の Node.js クライアントを探しています
Node.js を使用してアプリケーションを作成しており、Message Hub クライアントまたはライブラリに興味があります。
Message Hub 用の公式の Node.js クライアントはありますか?
ibm-cloud - Bluemix のメッセージ ハブへの接続のタイムアウト
メッセージ ハブ サービスに接続しようとしています。REST API を使用すれば接続できますが、Java プログラムから接続しようとすると、常にタイムアウトが発生します。
次の構成を使用しています。
しばらくするとエラーが
私はkafka-clientsバージョン0.9.0.0を使用しています
何かご意見は？
ibm-cloud - Bluemix からの Message-Hub サービス上のパーティション
この機能はまだありませんが、今後提供される予定はありますか?
apache-kafka - IBM Bluemix Message Hub プロデューサーのメッセージ形式
bluemix.net の「Getting started with Message Hub (BETA)」ページは、Java プロデューサーの場合、「...メッセージは [{ "value" : string }, ...] ".
Kafka のドキュメントでこの形式への参照を見つけることができません。サービスは、その形式ではないテキストが送信されたときに完全に正常に動作し、それを使用しようとしたときに、消費者は複数の「値」文字列を分離しませんでした。値が単一の JSON メッセージとして到着しました。
では、この規定された要件の起源、必要性、または潜在的な利点について考えている人はいますか?
apache-kafka - 小さなメッセージでの Kafka Producer 0.9 のパフォーマンスの問題
小さなメッセージを送信するとき、Java Kafka Producer 0.9 クライアントで非常に低いパフォーマンスが観察されています。メッセージは大きな要求バッチに蓄積されないため、小さなレコードがそれぞれ個別に送信されます。
クライアント構成の何が問題になっていますか? それとも、これは別の問題ですか？
Kafka クライアント 0.9.0.0 を使用します。Kafka の未リリースの 9.0.1 または 9.1 の修正済みリストまたは未解決リストに関連する投稿は見られなかったため、クライアント構成とサーバー インスタンスに焦点を当てています。
linger.ms によって、クライアントがレコードをバッチに蓄積する必要があることは理解しています。
linger.ms を 10 に設定しました (そして 100 と 1000 も試しました) が、これらはバッチ蓄積レコードにはなりませんでした。レコード サイズが約 100 バイトで、リクエスト バッファ サイズが 16K の場合、1 回のリクエストで約 160 個のメッセージが送信されると予想されます。
クライアントでのトレースは、新しい Bluemix Messaging Hub (Kafka Server 0.9) サービス インスタンスを割り当てたにもかかわらず、パーティションがいっぱいである可能性があることを示しているようです。テスト クライアントは、他の I/O なしで複数のメッセージをループで送信しています。
ログには、「トピック mytopic パーティション 0 がいっぱいになっているか、新しいバッチを取得しているため、送信者を目覚めさせる」という疑わしい行を含む繰り返しシーケンスが表示されます。
テスト ケースでは、新しく割り当てられたパーティションは本質的に空である必要があります。
次のプロパティ ファイルが用意されています。
Kafka クライアントは、展開/マージされた構成リストを表示します (および linger.ms 設定を表示します)。
100 レコードを送信した後の Kafka メトリクス:
ありがとう
java - Apache Kafka クライアントが「バッチ期限切れ」例外をスローするのはいつですか?
Apache Kafka Java クライアント (0.9) を使用して、 Kafka Producer クラスを使用して長い一連のレコードをブローカーに送信しようとしています。
非同期送信メソッドは、しばらくの間すぐに戻り、その後、各呼び出しで短時間ブロックを開始します。約 30 秒後、クライアントは例外 ( TimeoutException ) のスローを開始し、メッセージ"Batch expired"が表示されます。
この例外がスローされる原因は何ですか?
ibm-cloud - アプリの実行中に変更されたサービスの資格情報
アプリの実行中に VCAP_SERVICES の資格情報 (API キー/ユーザー名/パスワード) を変更することはできますか?
node.js アプリにバインドされた 2 つのサービス (メッセージ ハブと sendgrid) が、展開後すぐ (約 2 時間) に資格情報を変更したことがわかりました。その結果、資格情報を保存していたため、これらのサービスへのすべての接続が失敗しました。アプリの起動時に変数に。以前に他の誰かに起こったことがありますか？それは正常ですか？そのシナリオを処理するための最良のアプローチは何ですか?
apache-kafka - クライアント ID 認証は Kafka API で機能しなくなりました
Message Hub Kafka インターフェースを使用して、client.id 認証を使用していた Bluemix アプリが Kafka ブローカーによって拒否された接続を取得していることを発見しました。これを修正するにはどうすればよいですか?