問題タブ [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 - kafka python - Bluemix MessageHub - ConnectionError: ソケットが切断されました
メッセージ ハブにメッセージをプッシュするために kafka python クライアントを使用していますが、しばらくアプリを実行すると、メッセージ ハブへのメッセージの送信が停止することに気付きました。
その後、ログ ファイルで次のことに気付きました。
コードを更新して追加しましたretries=5：
私のコードは python フラスコ アプリから実行されます。着信する特定のタイプのすべてのリクエストがsend_message()メソッドを呼び出します。
以下は、Bluemix からの関連するログ行です。1 行か 2 行のコピーと貼り付けを見逃している可能性がありますが、何が起こっているのかを理解するのに十分であることを願っています。
私のトピックは存在します。私の完全なクライアント コードはこちら: https://github.com/snowch/movie-recommender-demo/blob/effc981cc9f799c41952719619f693172eebcd6a/web_app/app/messagehub_client.py
最も高く評価されているポインタ...
apache-kafka - Jass ログイン モジュールを使用せずに IBM Message Hub への認証を行う方法
Liberty for Java アプリを使用して、Bluemix で kafka-message-hub への接続をセットアップしようとしました。ドキュメントとgitリポジトリの例に従いました。ファイルを正常に作成/使用し、jaas.confログインしていると言います。ただし、メッセージが書き込まれると、「60000ミリ秒後にメタデータを更新できませんでした」と表示されます。メッセージを書き込むために、次のコードをserver.xmlファイルに追加する必要がありました。
ただし、ドキュメントには次のように記載されています (「Kafka クライアントを 0.9.x から 0.10.x に移行する方法」の下):
- Message Hub ログイン Jar モジュールを削除します。
jaas.confファイルを次のコードに変更します。
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
serviceName="kafka"
username="<your username>"
password="<your password>";
};
- 次の行をコンシューマ プロパティとプロデューサー プロパティに追加します。
sasl.mechanism=PLAIN
ここで何か不足していますか？このモジュールはもう必要ないと指示されているようですが、それなしでは機能しません。
java - Bluemix Liberty から BlueMix MessageHub に接続できない
Bluemix Message Hub に接続する liberty アプリがあります。ローカルでは正常に動作しますが、Bluemix Liberty から liberty アプリを実行するとまったく動作しません。https://github.com/ibm-messaging/message-hub-samples/tree/master/kafka-java-liberty-sampleの例に従っています。ここでは、実行時に server.xml で username/pw を変更します。
試行錯誤の結果、server.xml で kafka ユーザー名/pw をハードコーディングすると、BluemixLiberty が MsgHub に正常に接続することがわかりました。例のようにkafkaのユーザー名/pwを「ホットスワップ」すると、機能せず、kafkaに接続しません(サービスを再起動しても再接続しません)。CF を使用してサービスにログインして確認しましたが、sever.xml でユーザー名/パスワードが正しくスワップされています。
この機能は Bluemix Liberty でサポートされていますか? そうでない場合、vcap-services を適切に使用して、実稼働ユーザー/pw をハードコーディングしないようにするにはどうすればよいですか?