java.lang.RuntimeException: java.io.EOFException

hortonworks.com | 2 months ago
  1. 0

    Exception from Kafka Sink in a Flume Agent

    Stack Overflow | 2 months ago | Learner
    kafka.common.KafkaException: fetching topic metadata for topics [Set(SAMPLETOPIC)] from broker [ArrayBuffer(BrokerEndPoint(0,sample.node,9093))] failed
  2. Speed up your debug routine!

    Automated exception search integrated into your IDE

  3. 0

    Java streams with EOFException

    Stack Overflow | 4 years ago | user2224638
    java.io.EOFException
  4. 0

    Reading integer values from binary file using Java

    Stack Overflow | 6 years ago | rozar
    java.io.EOFException

  1. max_samebug 4 times, last 3 months ago
4 unregistered visitors
Not finding the right solution?
Take a tour to get the most out of Samebug.

Tired of useless tips?

Automated exception search integrated into your IDE

Root Cause Analysis

  1. java.io.EOFException

    No message provided

    at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel()
  2. Apache Kafka
    NetworkReceive.readFromReadableChannel
    1. org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83)[stormjar.jar:?]
    1 frame
  3. Apache Kafka
    SimpleConsumer.getOffsetsBefore
    1. kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:129)[stormjar.jar:?]
    2. kafka.network.BlockingChannel.receive(BlockingChannel.scala:120)[stormjar.jar:?]
    3. kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:99)[stormjar.jar:?]
    4. kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$sendRequest(SimpleConsumer.scala:83)[stormjar.jar:?]
    5. kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:149)[stormjar.jar:?]
    6. kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79)[stormjar.jar:?]
    6 frames
  4. storm.kafka
    KafkaSpout.nextTuple
    1. storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:74)[stormjar.jar:?]
    2. storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:64)[stormjar.jar:?]
    3. storm.kafka.PartitionManager.<init>(PartitionManager.java:89)[stormjar.jar:?]
    4. storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98)[stormjar.jar:?]
    5. storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoordinator.java:69)[stormjar.jar:?]
    6. storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:135)[stormjar.jar:?]
    6 frames
  5. backtype.storm.daemon
    executor$fn__7177$fn__7192$fn__7221.invoke
    1. backtype.storm.daemon.executor$fn__7177$fn__7192$fn__7221.invoke(executor.clj:596)[storm-core-0.10.0.2.4.0.0-169.jar:0.10.0.2.4.0.0-169]
    1 frame
  6. backtype.storm
    util$async_loop$fn__544.invoke
    1. backtype.storm.util$async_loop$fn__544.invoke(util.clj:475)[storm-core-0.10.0.2.4.0.0-169.jar:0.10.0.2.4.0.0-169]
    1 frame
  7. Clojure
    AFn.run
    1. clojure.lang.AFn.run(AFn.java:22)[clojure-1.6.0.jar:?]
    1 frame
  8. Java RT
    Thread.run
    1. java.lang.Thread.run(Thread.java:745)[?:1.8.0_71]
    1 frame