1

スパークストリーミングの例を実行すると、フォローをorg.apache.spark.examples.streaming.JavaDirectKafkaWordCountキャッチしました。どうすれば解決できますかEOFException

Exception in thread "main" org.apache.spark.SparkException: java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.
java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.
java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.
    at org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$createDirectStream$2.apply(KafkaUtils.scala:413)
    at org.apache.spark.streaming.kafka.KafkaUtils$$anonfun$createDirectStream$2.apply(KafkaUtils.scala:413)
    at scala.util.Either.fold(Either.scala:97)
    at org.apache.spark.streaming.kafka.KafkaUtils$.createDirectStream(KafkaUtils.scala:412)
    at org.apache.spark.streaming.kafka.KafkaUtils$.createDirectStream(KafkaUtils.scala:528)
    at org.apache.spark.streaming.kafka.KafkaUtils.createDirectStream(KafkaUtils.scala)
4

1 に答える 1

1

ダイレクト ストリームは下位の低レベルの Kafka コンシューマーを使用するため、ブローカーのリストを提供する必要があります。metadata.broker.listほとんどの場合、まだフォームにプロパティを設定していない可能性がありますbhost1:9092,bhost2:9092,...,bhostN:9092。

Kafka SimpleConsumer cannot connect to Zookeeper : Received -1 when reading from channelも参照してください。

于 2015-08-14T17:20:15.107 に答える