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

Google Groups | Unknown author | 4 months ago
  1. 0

    Try to query against Kafka Topic and get "socket has likely been closed."

    Google Groups | 4 months ago | Unknown author
    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.Utils$.read()
    2. Apache Kafka
      SimpleConsumer.send
      1. kafka.utils.Utils$.read(Utils.scala:381)
      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:111)
      6. kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
      7. kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68)
      8. kafka.consumer.SimpleConsumer.send(SimpleConsumer.scala:91)
      9. kafka.javaapi.consumer.SimpleConsumer.send(SimpleConsumer.scala:68)
      9 frames
    3. com.facebook.presto
      KafkaSplitManager.getSplits
      1. com.facebook.presto.kafka.KafkaSplitManager.getSplits(KafkaSplitManager.java:83)
      1 frame
    4. presto-main
      QueuedExecution.lambda$start$1
      1. com.facebook.presto.split.SplitManager.getSplits(SplitManager.java:45)
      2. com.facebook.presto.sql.planner.DistributedExecutionPlanner$Visitor.visitTableScan(DistributedExecutionPlanner.java:112)
      3. com.facebook.presto.sql.planner.DistributedExecutionPlanner$Visitor.visitTableScan(DistributedExecutionPlanner.java:92)
      4. com.facebook.presto.sql.planner.plan.TableScanNode.accept(TableScanNode.java:135)
      5. com.facebook.presto.sql.planner.DistributedExecutionPlanner$Visitor.visitAggregation(DistributedExecutionPlanner.java:192)
      6. com.facebook.presto.sql.planner.DistributedExecutionPlanner$Visitor.visitAggregation(DistributedExecutionPlanner.java:92)
      7. com.facebook.presto.sql.planner.plan.AggregationNode.accept(AggregationNode.java:189)
      8. com.facebook.presto.sql.planner.DistributedExecutionPlanner.plan(DistributedExecutionPlanner.java:78)
      9. com.facebook.presto.sql.planner.DistributedExecutionPlanner.plan(DistributedExecutionPlanner.java:83)
      10. com.facebook.presto.execution.SqlQueryExecution.planDistribution(SqlQueryExecution.java:303)
      11. com.facebook.presto.execution.SqlQueryExecution.start(SqlQueryExecution.java:226)
      12. com.facebook.presto.execution.QueuedExecution.lambda$start$1(QueuedExecution.java:62)
      12 frames
    5. Java RT
      Thread.run
      1. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      2. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      3. java.lang.Thread.run(Thread.java:745)
      3 frames