You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/07/12 22:23:00 UTC

[jira] [Resolved] (KAFKA-3145) CPU Usage Spike to 100% when network connection is to error port

     [ https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dong Lin resolved KAFKA-3145.
-----------------------------
    Resolution: Cannot Reproduce

> CPU Usage Spike to 100% when network connection is to error port
> ----------------------------------------------------------------
>
>                 Key: KAFKA-3145
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3145
>             Project: Kafka
>          Issue Type: Bug
>          Components: producer 
>    Affects Versions: 0.8.2.1, 0.9.0.0
>            Reporter: zhiwei
>            Assignee: Dong Lin
>            Priority: Major
>
> CPU spike to 100% when network connection is to error port.
> It seems network IO thread are very busy logging following error message. 
> [2016-01-25 14:09:12,476] ERROR Uncaught error in kafka producer I/O thread:  (org.apache.kafka.clients.producer.internals.Sender)
> java.lang.IllegalStateException: Invalid request (size = -1241382912)
> 	at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:68)
> 	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)
> [2016-01-25 14:09:12,479] ERROR Uncaught error in kafka producer I/O thread:  (org.apache.kafka.clients.producer.internals.Sender)
> java.lang.NullPointerException
> 	at org.apache.kafka.common.network.NetworkReceive.complete(NetworkReceive.java:48)
> 	at org.apache.kafka.common.network.Selector.poll(Selector.java:249)
> 	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)
> [2016-01-25 14:09:12,480] ERROR Uncaught error in kafka producer I/O thread:  (org.apache.kafka.clients.producer.internals.Sender)
> java.lang.NullPointerException
> 	at org.apache.kafka.common.network.NetworkReceive.complete(NetworkReceive.java:48)
> 	at org.apache.kafka.common.network.Selector.poll(Selector.java:249)
> 	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)
> [2016-01-25 14:09:12,480] ERROR Uncaught error in kafka producer I/O thread:  (org.apache.kafka.clients.producer.internals.Sender)
> java.lang.NullPointerException
> 	at org.apache.kafka.common.network.NetworkReceive.complete(NetworkReceive.java:48)
> 	at org.apache.kafka.common.network.Selector.poll(Selector.java:249)
> 	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)
> [2016-01-25 14:09:12,481] ERROR Uncaught error in kafka producer I/O thread:  (org.apache.kafka.clients.producer.internals.Sender)
> java.lang.NullPointerException
> 	at org.apache.kafka.common.network.NetworkReceive.complete(NetworkReceive.java:48)
> 	at org.apache.kafka.common.network.Selector.poll(Selector.java:249)
> 	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)
> Thanks,



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)