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インスタンスに接続しようとすると、データが消費されます。 この問題を解決するにはどうすればよいですか?
com.datastax.driver.core.ControlConnectionタイムアウトがカフカ問題であることを確認してください。私はcom.datastax.driver.coreがCassandra関連のパッケージであることを知っています。 –