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

Question

この質問は、why do I need to poll message hubに関連しています。その回答にリンクされているドキュメントには、カフカは「長い投票」の概念をサポートしていますが、そのようなメカニズムを実装するためのメッセージハブのための既存のノードjのサポートnodejsに提供されるデモアプリケーションは、サーバからのメッセージの取得を処理するために250mSecタイマーインターバルを使用するだけです。私はそれをKafkaのlong-pollのアプローチを使ってより洗練されたロングポールアプローチに置き換えたいと思います： To avoid this we have parameters in our pull request that allow the consumer request to block in a "long poll" waiting until data arrives しかし、既存の実装ではこのような種類のパラメータを設定することはできませんし、必要なパラメータは次のようになります。 get関数のプロトタイプは次のように定義されています。

MessageHub.ConsumerInstance.prototype.get(topicName [toValue]) 

Retrieves a message from the provided topic name. 

    topicName - (String) (required), the topic to retrieve messages from. 
    toValue - (Boolean) (optional), unwraps base64 encoded messages, if true. Defaults to true. 

Returns a Promise object which will be fulfilled when the request to the service resolves. 

設定オプションはありません。または、message-hub.jsモジュールに実装されているURLのURLと利用可能なオプションを定義するドキュメントをリンクしてください。あなたが言及しているものは、メッセージのハブが提供するRESTのAPIの上に構築されたNPMモジュールであることを

Answer 1

- NPMが提供されていないことを基本的にコンフルエントRESTプロキシAPIマイナスAVROサポート http://docs.confluent.io/2.0.1/kafka-rest/docs/api.html

ある あなたは完全なカフカのAPIです。それは、RESTのAPI

カフカドキュメントが参照するJavaの消費者調査でタイムアウトであるロングポーリングのサブセットだけを提供しています https://kafka.apache.org/0102/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#poll(long)

Node.jsのための良いクライアントが https://github.com/Blizzard/node-rdkafka

です

サンプルコード https://github.com/ibm-messaging/message-hub-samples