You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Rui Zhang (JIRA)" <ji...@apache.org> on 2018/12/28 20:07:00 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=16730461#comment-16730461 ] 

Rui Zhang commented on KAFKA-2078:
----------------------------------

we have same problem: our client is 0.8.2 and server is 0.10.2.2.  Here is warn msg detail

 

WARN  kafka-producer-network-thread | producer-73 Selector:276 - Error in I/O with xxxx/some IP
 java.net.ConnectException: Connection timed out: no further information
         at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
         at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
         at org.apache.kafka.common.network.Selector.poll(Selector.java:238)
         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)

 

 

compression.type = none
         metric.reporters = []
         metadata.max.age.ms = 300000
         metadata.fetch.timeout.ms = 60000
         acks = all
         batch.size = 16384
         reconnect.backoff.ms = 10
         bootstrap.servers = [some servers]
         receive.buffer.bytes = 32768
         retry.backoff.ms = 100
         buffer.memory = 33554432
         timeout.ms = 30000
         key.serializer = class org.apache.kafka.common.serialization.StringSerializer
         retries = 0
         max.request.size = 1048576
         block.on.buffer.full = true
         value.serializer = class org.apache.kafka.common.serialization.StringSerializer
         metrics.sample.window.ms = 30000
         send.buffer.bytes = 131072
         max.in.flight.requests.per.connection = 5
         metrics.num.samples = 2
         linger.ms = 0
         client.id =

 

 

> 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
>            Priority: Major
>
> 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
(v7.6.3#76005)