message-hub

0熱

1答えて

私の現在のインスタンスが購読されていないトピックのカフカ警告を見ました。私たちは同じカフカブローカーを使い、それぞれの開発者は自分の話題を持っています。しかし、我々はすべて、プロパティー・ファイルで指定された同じデフォルトのgroupID/clientidを使用します。 2017-06-27T11:48:35.20-0400 [APP/PROC/WEB/0]OUT 2017-06-27 15:48

1熱

1答えて

Apache Kafkaシステムエラー処理

私たちはメッセージブローカーソリューションとしてKafkaを実装しようとしています。私たちはSpring BootマイクロサービスをIBM BLuemixに導入しています。内部メッセージブローカーの実装はKafkaバージョン0.10です。私の経験はJMS、ActiveMQの方が多いので、Javaのコンシューマのシステムレベルのエラーを処理するにはどうすればよいでしょうか？ここでは、我々が現在消

0熱

1答えて

kafka python - Bluemix MessageHub - ConnectionError：socket disconnected

私はkafka pythonクライアントを使ってメッセージをMessage Hubにプッシュしていますが、メッセージハブへのメッセージの送信を中断してしまったことに気付きました。私はその後、私のログファイルに次のように気づい： ConnectionError: socket disconnected 私はretries=5を追加するために自分のコードを更新： from kafka impor

0熱

1答えて

IBM Message Hubでトピックを作成しようとしたときに403 Unauthorizedが発生する理由

IBM Message Hubの新しいインスタンスをBluemixに作成し、Kafka Javaクライアントを使用して（ラップトップから）リストに追加できますトピック。私はないできること（改行はわかりやすくするために追加された）管理REST APIを介して、トピックを作成します： curl -H "Content-Type: application/json" -H "X-Auth-To

0熱

2答えて

なぜメッセージハブをポーリングする必要がありますか？

私はblue-mixのmessage-hubのnode-js expressの例を見ています。私はなぜサーバーからメッセージハブをポーリングする必要があるのか疑問に思っています。私は、パブ・サブモデルの背後にある考え方全体が、私のサーバーがメッセージ・サービスをポーリングして消費する新しいメッセージがあるかどうかを調べる必要がないことだと考えました。提供された例では、app.jsファイルの行2

0熱

1答えて

NodeJSでBluemixメッセージハブを使用して「長い投票」を設定するには

この質問は、why do I need to poll message hubに関連しています。その回答にリンクされているドキュメントには、カフカは「長い投票」の概念をサポートしていますが、そのようなメカニズムを実装するためのメッセージハブのための既存のノードjのサポートnodejsに提供されるデモアプリケーションは、サーバからのメッセージの取得を処理するために250mSecタイマーインターバルを

0熱

1答えて

メッセージハブでサービスクレデンシャルをカスタマイズする方法

bluemixでメッセージハブインスタンスを作成すると、画面にサービスクレデンシャルタブが表示されます。「ユーザー」：「XXXXXXXXXXXXXXXX」、「パスワード」：データはJSON形式で、編集することはできませんです「xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx」ユーザ名とパスワードをカスタマイズしたり編集するためのいずれかの方法がありますか？

1熱

1答えて

BlueMix MessageHubに接続できませんBluemix Libertyから

私はBluemix Message Hubに接続するリバティーアプリを持っています。それはローカルでうまく動作しますが、私はBluemix Libertyからリバティーアプリを実行するとうまくいかないのです。私はhttps://github.com/ibm-messaging/message-hub-samples/tree/master/kafka-java-liberty-sampleの例に従

2熱

1答えて

curlコマンドでメッセージハブにトピックを作成

curlコマンドを使用してMessage-Hubにトピックを作成しようとしています。私はこのYAMLを追っ：https://github.com/ibm-messaging/message-hub-docs/blob/master/kafka-administration-api/KafkaTopicManagement.yaml 私は次のことを実行するときに許可されていませんHTTP 405メ

0熱

1答えて

カフカGolangクライアントは、これは私が実行しているかのコードスニペットで

メッセージハブサービスへの接続に失敗： err := godotenv.Load() if err != nil { log.Fatal("Error loading .env file") } broker := os.Getenv("BROKER") topic := os.Getenv("TOPIC") username := os.Getenv("USE