問題タブ [twitter-hbc]

hbc ツールを使用して、ストリーミング Api を使用してアプリを構築しています。トラックワードやその他のフィルターを使用せずに、パブリック ストリーミング フローを取得したいだけです。どうすればそれを行うことができますか？ここに私が書いたコードのサンプルがあります:

これにより、ツイートを追跡することはできますが、ツイートのすべての公開フローを追跡することはできません。ご回答ありがとうございます^^

Twitter の hbc 依存関係を pom.xml に追加すると、エラーが発生します。ここからの指示に従いました。わかりません。依存関係の問題だった場合は、Web で修正を見つける必要がありましたが、その依存関係をコメントアウトすると、サーバーが起動します。

これは私が pom.xml に追加したものです:

これはエラーです：

Apache Flink Streaming API を使用して Twitter のツイートを読み取る小さな Scala プログラムを作成しました。

実行すると、次の問題が発生します。

プログラムは接続を再確立しようとします。したがって、この 4 行のログ メッセージは引き続き出力されます。

これに関する奇妙な点は、Apache Flink プロジェクトで提供されている例を実行すると、すべてが正常に機能することです (マスターの最新バージョンを GitHub から取得しました)。私も同じプロパティファイルを使用しています。そのサンプル クラスを自分のプロジェクトにコピーすると、上記の問題状態も発生します。

Flink アーキタイプを使用して、独自のプロジェクトを作成しました。バージョン 0.9.1 と 0.10-SNAPSHOT で試しました。依存関係flink-scala、flink-streaming-scala、flink-clientsおよびflink-connector-twitterは、対応するバージョンで使用されます。

誰かが同様の問題を経験したことがあり、私を正しい軌道に乗せることができますか?

Eclipse Luna を使用して、非推奨の Google コレクションをインポートする Java コードを実行しようとしていますが、最新の Guava バージョンでコンパイルすると例外がスローされます。

プラグインから com.google.guava_15.0.0.v201403281430 ファイルを削除しようとしましたが、コメントでここで説明されているようにグアバの古いバージョンを貼り付けようとしましたが、古いグアバ バージョンにインストール (ポイント) できません。また、この問題には別の解決策があるかもしれませんが、私はJavaが初めてで、そのリストを他のリストに置き換える方法がわかりません。

他の List メソッドを使用してそのコードを実行できる人はいますか? または、古いバージョンの Guava を eclipse に追加する方法を教えてください (スレッドから読み取るだけでその問題を解決できるかどうかはわかりません) または他の解決策を教えてください。ありがとうございました

hbc twitter api との切断に対処する方法がわかりません。ドキュメントには、発生したエラーの種類に応じて再接続の試行を遅くする必要があると書かれています。発生したエラーの種類はどこで確認できますか? それはmsgQueue、eventQueue またはどこにありますか?

twitter ストリーミング API が接続されているか、切断されているかを確認するにはどうすればよいですか? この情報を格納する変数はありますか?

失敗すると、Twitter Hosebird クライアント (hbc) は内部的に API への再接続を試みます。この情報はログに記録されます。接続の応答ステータスを変数で取得するにはどうすればよいですか?

ストリーミング API を使用して、特定のアカウントからツイートを取得できます。以下のように、特定の #tags のツイートを取得することもできます。

と

特定のユーザー (@myTwitter) から特定のツイート (#yolo) を取得したいので、これら 2 つのクエリをマージする方法を考えています。

コードはここにあり ます https://github.com/twitter/hbc