streaming

0熱

1答えて

私は人と共有することを意味するパーソナライズされた動的なキャンバスを持っていますが、古いブラウザ（IE < 9）ではサポートされていないタグを知っていますので、。私はサーバーで人の代わりにキャンバスをブラウズし、webRTCを通してタブの内容（キャンバス）のライブストリームを共有する予定です。 GoogleのtabCapture APIを使用してタブのコンテンツを取得し、nodeJSサーバーでS

0熱

1答えて

aws kinesisストリームより遅いレートでラムダにデータを送信

aws kinesisストリーム&ラムダを使用して、ある種のストリームソリューションを実装する必要があります。ストリームにデータを追加するための最初のラムダを追加しました。最初のLambda自体は10秒ごとに呼び出され、100データリクエスト（1kbごとに1つずつ）をストリームに追加します。私はラムダを起動するスクリプトの2つのインスタンスを実行しています。上記ストリームをトリガとして使用する2

0熱

1答えて

Twitter Streaming API - Objective-C

私はTwitter REST/Streaming APIと一緒に働いています。 REST APIにアクセスするには、NSMutableURLRequest（アクセストークンやクエリなどのパラメータが含まれています）を作成します。私はNSURLSessionと一緒に要求を使用してデータを読み込みます。変更可能な要求オブジェクトを作成するライブラリを使用しています（要求オブジェクトを使用しない場合、T

0熱

1答えて

Kafkaストリームの単語数アプリケーション

私はkafkaストリーミングAPI（Kakfaバージョン：0.10.2.0）を使って簡単な単語の数を試しています。Wordcount App gist。 ./kafka-console-producer.sh -topic input-topic --broker-list localhost:9092 ./kafka-console-consumer.sh --topic output-topi

0熱

1答えて

kafkaコンシューマは複数のトピックを消費する場合、同じトピックキーを扱いますか？

はのは、私は2つのカフカのトピックログインとユーザ名とパーティションの等しい数を持つことによって仕切られログアウトがあるとしましょう。両方のトピックを消費する2人のコンシューマのコンシューマグループを実行すると、各ユーザーのログインイベントとログアウトイベントが同じコンシューマによって処理されることを確認できますか？

0熱

1答えて

kafkaストリームをシンクしている間にメッセージが表示されず、メッセージが表示されません。1.2

私の目標はkafkaを使用してjson形式の文字列を読み込み、文字列にフィルターをかけてメッセージを取り出すことですフォーマット）。テストの目的のために、私の入力文字列のメッセージがどのように見える： {"a":1,"b":2} と実装の私のコードは次のとおりです。 def main(args: Array[String]): Unit = { // parse input argume

0熱

1答えて

json形式の文字列の一部をFlinkでKafkaから抽出する方法012

私の目標は、kafkaを使用してjson形式の文字列を読み込み、文字列にフィルターをかけて、の部分を選択してメッセージをシンクしてメッセージを出力します（まだjsonの文字列形式です）。テストの目的のために、私の入力文字列メッセージは次のようになります。 {"a":1,"b":2，"c":"3"} と実装の私のコードです： def main(args: Array[String]): Uni

1熱

2答えて

Flink 1.2はストリーミングプログラミングでPythonをサポートしていますか？

オンラインのPythonプログラミングガイドへ： https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/python.html kafkaコネクタなどのストリーミングプログラミングに関する資料はありませんでした。また、git hubの例（https://github.com/apache/flink/tree/

-7熱

1答えて

パラメータの長いクリックを追加する

このアプリは、ユーザーがnアーティストからストリーミングできる場所から作成しました。このアプリケーションを構築する際には、常にonclick属性のみを使用していました。しかし、今はそれぞれのアーティストの名前を長時間クリックしてトーストがポップアップできるようにしたいと思っています。誰でも私にlongclickオプションを持つのを手伝ってもらえますか？ありがとうございます。単にリストビュー上

0熱

1答えて

火花が

を複製onQueryProgress、私が見つかりました。私は1つのメッセージを送るなぜ結果が Query made progress: { "id" : "e76a8789-738c-49f6-b7f4-d85356c28600", "runId" : "d8ce0fad-db38-4566-9198-90169efeb2d8", "name" : null,