問題タブ [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.
elasticsearch - IBM Message Hub に接続している kafka 入力プラグインでの回復不能なエラー
logstash から IBM Message Hub を使用しようとしています。私のlogstash.conf：
Message Hub Consumer exampleに基づくと、次の kafka 構成プロパティがありません。
ただし、logstash のドキュメントから、これらを設定する方法を確認できませんでした。
私の kafka_jaas.conf ファイルは次のようになります。
結果は
Message Hub アカウントをお持ちの場合は、私の問題を簡単に再現できます。
（最新のlogstash、現在5.6.2でも同じ問題があります）
node.js - 3 つ以上のトピックをサブスクライブすると Kafka コンシューマーがメッセージを受信しない
node-rdkafka ( https://github.com/Blizzard/node-rdkafka ) を使用して、IBM Bluemix Message Hub からメッセージを消費および生成しています。ノード プロセスごとに最大 2 つのトピックのみをサブスクライブする限り、問題なくメッセージを消費および生成できます。3 つ以上のトピックをサブスクライブするとすぐに、コンシューマーはサブスクライブされたトピックに関するメッセージを受信しなくなります。エラーはありません。
ここにソフトリミットはありますか？または、私のコードにこの問題の原因となっているものがありますか? サーバーのメモリを増やしても効果がないようです。
プロデューサー コード:
消費者：
助言がありますか？