java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.

Stack Overflow | ruben123 | 3 months ago
  1. 0

    Not able to send json tweets events to Kafka topic/producer using kafka command line

    Stack Overflow | 3 months ago | ruben123
    java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.
  2. 0

    kafka使用异常 - 小象问答-hadoop,spark,storm,R,hive,hbase,redis,大数据问答社区

    chinahadoop.cn | 8 months ago
    java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.
  3. 0

    Kafka performance test failed

    apache.org | 1 year ago
    java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Exception running kafka-console-producer.sh (0.8.1.1)

    Stack Overflow | 2 years ago | Raylite3
    kafka.common.KafkaException: fetching topic metadata for topics [Set(test)] from broker [ArrayBuffer(id:0,host:localhost,port:2181)] failed
  6. 0

    GitHub comment 113#136670459

    GitHub | 1 year ago | tymofii-polekhin
    java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.

    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

      Received -1 when reading from channel, socket has likely been closed.

      at kafka.utils.CoreUtils$.read()
    2. Apache Kafka
      DefaultEventHandler$$anonfun$partitionAndCollate$1.apply
      1. kafka.utils.CoreUtils$.read(CoreUtils.scala:193)
      2. kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
      3. kafka.network.Receive$class.readCompletely(Transmission.scala:56)
      4. kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
      5. kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
      6. kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77)
      7. kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:74)
      8. kafka.producer.SyncProducer.send(SyncProducer.scala:115)
      9. kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
      10. kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
      11. kafka.producer.BrokerPartitionInfo.getBrokerPartitionInfo(BrokerPartitionInfo.scala:49)
      12. kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartitionListForTopic(DefaultEventHandler.scala:188)
      13. kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:152)
      14. kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:151)
      14 frames
    3. Scala
      ArrayBuffer.foreach
      1. scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
      2. scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
      2 frames
    4. Apache Kafka
      ProducerSendThread$$anonfun$processEvents$3.apply
      1. kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:151)
      2. kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:96)
      3. kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:73)
      4. kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
      5. kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
      6. kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
      6 frames
    5. Scala
      Stream.foreach
      1. scala.collection.immutable.Stream.foreach(Stream.scala:547)
      1 frame
    6. Apache Kafka
      ProducerSendThread.run
      1. kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
      2. kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
      2 frames