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

[zhiwei (JIRA)]

zhiwei created KAFKA-3145:
-----------------------------

             Summary: CPU Usage Spike to 100% when network connection is error
                 Key: KAFKA-3145
                 URL: https://issues.apache.org/jira/browse/KAFKA-3145
             Project: Kafka
          Issue Type: Bug
          Components: producer 
    Affects Versions: 0.9.0.0, 0.8.2.1
            Reporter: zhiwei
            Assignee: Jun Rao
             Fix For: 0.9.0.1




CPU spike to 100% when network connection is error.
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
(v6.3.4#6332)