2017-03-20 5 views
0

DSEとKafkaを使用して作成されたSparkストリーミングアプリケーションがあります。クラスタ仕様:3分析、2カッサンドラ、および1カフカノード。すべてec2インスタンスです。ストリーミングでは、KafkaでSparkストリーミングを使用します。com.datastax.driver.core.ControlConnection:[コントロールの接続] 60000ミリ秒で再試行をスケジューリングする任意のホストに接続できません

ERROR 2017-03-20 06:13:54,690 com.datastax.driver.core.ControlConnection:[制御接続]接続できません。カフカノードの数を3から1にダウングレードしました。任意のホストに60000ミリ秒で再試行をスケジュールする

ローカルマシンから同じkafkaインスタンスに接続しようとすると、データが消費されます。 この問題を解決するにはどうすればよいですか?

+0

com.datastax.driver.core.ControlConnectionタイムアウトがカフカ問題であることを確認してください。私はcom.datastax.driver.coreがCassandra関連のパッケージであることを知っています。 –

答えて

0

提案: すべてがec2インスタンス内にある場合は、プライベートIP経由で接続してください。 AWSの方がはるかに高速でコスト効率が良い。

+0

プライベートIP、パブリックIP、パブリックDNS、ローカルホストも試してみましたが、何も助けてくれませんでした。 –

関連する問題