You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Sayat Satybaldiyev (JIRA)" <ji...@apache.org> on 2015/06/16 16:14:02 UTC
[jira] [Commented] (KAFKA-2078) Getting Selector [WARN] Error in
I/O with host java.io.EOFException
[ https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588083#comment-14588083 ]
Sayat Satybaldiyev commented on KAFKA-2078:
-------------------------------------------
I got the same error on Amazon instance. Both producer and Kafka is running on EC2.
Kafka:
kafka_2.10-0.8.2.0
with 1 broker and default settings, except log retention:
log.retention.hours=1
log.retention.bytes=10737418240
log.segment.bytes=1073741824
Java Producer:
0.8.2.0.
Error:
2015-06-16 09:41:54 [kafka-producer-network-thread | producer-1] WARN o.a.kafka.common.network.Selector - Error in I/O with ip-172-31-5-93.us-west-2.compute.internal/172.31.5.93
java.io.EOFException: null
at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:62) ~
at org.apache.kafka.common.network.Selector.poll(Selector.java:248) ~
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_79]
```
Looks like Kafka Producer caught the exception https://github.com/apache/kafka/blob/0.8.2.0/clients/src/main/java/org/apache/kafka/common/network/Selector.java#L276 .
Would producer establish a new connection and resend a messages in queque?
Thanks!
> Getting Selector [WARN] Error in I/O with host java.io.EOFException
> -------------------------------------------------------------------
>
> Key: KAFKA-2078
> URL: https://issues.apache.org/jira/browse/KAFKA-2078
> Project: Kafka
> Issue Type: Bug
> Components: producer
> Affects Versions: 0.8.2.0
> Environment: OS Version: 2.6.39-400.209.1.el5uek and Hardware: 8 x Intel(R) Xeon(R) CPU X5660 @ 2.80GHz/44GB
> Reporter: Aravind
> Assignee: Jun Rao
>
> When trying to Produce 1000 (10 MB) messages, getting this below error some where between 997 to 1000th message. There is no pattern but able to reproduce.
> [PDT] 2015-03-31 13:53:50 Selector [WARN] Error in I/O with "our host" java.io.EOFException at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:62) at org.apache.kafka.common.network.Selector.poll(Selector.java:248) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122) at java.lang.Thread.run(Thread.java:724)
> This error I am getting some times @ 997th message or 999th message. There is no pattern but able to reproduce.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)