[jira] [Commented] (KAFKA-2546) CPU utilization very high when no kafka node alive

[diego (JIRA)]

    [ 
https://issues.apache.org/jira/browse/KAFKA-2546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14743793#comment-14743793
 ] 

diego commented on KAFKA-2546:
------------------------------

Here's a sample stacktrace:

        at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413)
        at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409)
        at kafka.utils.ZkUtils$.getChildrenParentMayNotExist(ZkUtils.scala:469)
        at kafka.utils.ZkUtils$.getAllBrokersInCluster(ZkUtils.scala:81)
        at kafka.client.ClientUtils$.channelToAnyBroker(ClientUtils.scala:114)
        at 
kafka.client.ClientUtils$.channelToOffsetManager(ClientUtils.scala:151)
        at 
kafka.consumer.ZookeeperConsumerConnector.ensureOffsetManagerConnected(ZookeeperConsumerConnector.scala:178)
        at 
kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:128)
        at 
kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:66)
        at 
kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:69)
        at 
kafka.consumer.Consumer$.createJavaConsumerConnector(ConsumerConnector.scala:105)
        at 
kafka.consumer.Consumer.createJavaConsumerConnector(ConsumerConnector.scala)

> CPU utilization very high when no kafka node alive
> --------------------------------------------------
>
>                 Key: KAFKA-2546
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2546
>             Project: Kafka
>          Issue Type: Bug
>          Components: consumer
>    Affects Versions: 0.8.2.1
>            Reporter: diego
>            Assignee: Neha Narkhede
>            Priority: Minor
>
> If you call kafka.consumer.Consumer.createJavaConsumerConnector, and no 
> broker is found in ZK, you end up in 
> kafka.client.ClientUtils.channelToAnyBroker looping continuously with no wait 
> at all.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)