You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Sergey Romanov (JIRA)" <ji...@apache.org> on 2018/02/21 15:55:00 UTC

[jira] [Updated] (KAFKA-6575) Unhandled exception "NoRouteToHostException: No route to host"

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

Sergey Romanov updated KAFKA-6575:
----------------------------------
    Description: 
 

Step to reproduce:
 # Clone and open Strimzi sources [https://github.com/strimzi/strimzi]
 # Up cluster
{code:java}
$ oc clucter up{code}

 # Login as admin
{code:java}
$ oc login -u system:admin{code}

 # Deploy Cluster Controller
{code:java}
$ oc create -f resources/openshift/cluster-controller-with-template.yaml{code}

 # Deploy Topic Controller
{code:java}
$ oc create -f resources/openshift/topic-controller-with-template.yaml{code}

 # Login to OpenShift [https://127.0.0.1:8443|https://127.0.0.1:8443/]
 # Create "Apache Kafka (Ephemeral storage)"
 ## Click "Add to project"
 ## Click "Select from project"
 ## Select "Apache Kafka (Ephemeral storage)" and click "Next"
 ## Use default configurations:
 ### Number of Zookeper cluster nodes: 1
 ### Number of Kafka cluster nodes: 3
 ### Zookeeper healthcheck initial delay: 15
 ### Zookeeper healthcheck timeout: 5
 ## Click "Create" and wait for the message "Apache Kafka (Ephemeral storage) has been created"
 ## Open page "Pods" and wait when all pods will have status "Running"
 # Create Strimzi Topic Controller
 ## Click "Add to project"
 ## Click "Select from project"
 ## Select "Strimzi Topic Controller" and click "Next"
 ## Use default configurations
 ## Click "Create" and wait for the message "Success Strimzi Topic Controller has been created."
 ## Open page "Pods" and wait when all pods will have status "Running"
 # Open page "Config Maps" and open your cluster config
 # Edit value for zookeeper-healthcheck-delay
 ## Click "Actions"
 ## Click "Edit YAML"
 ## Set new value (30) for variable zookeeper-healthcheck-delay and save
 # Open page "Pods" and open logs for strimzi-topic-controller

Actual result:

Log has an unhandled exception:
{code:java}
[2018-02-21 15:48:18,807] WARN <ClientCnxn :1162> [.local:2181)] Session 0x161b8fedf870003 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.NoRouteToHostException: No route to host
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
Feb 21, 2018 3:48:18 PM io.vertx.core.impl.ContextImpl
SEVERE: Unhandled exception
java.lang.RuntimeException: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for for path: /brokers/topics
at io.strimzi.controller.topic.TopicsWatcher.lambda$start$2(TopicsWatcher.java:67)
at io.strimzi.controller.topic.zk.ZkImpl.lambda$null$9(ZkImpl.java:347)
at io.vertx.core.impl.ContextImpl.lambda$wrapTask$2(ContextImpl.java:344)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:403)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for for path: /brokers/topics
at org.apache.zookeeper.KeeperException.create(KeeperException.java:99)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
at io.strimzi.controller.topic.zk.ZkImpl.mapResult(ZkImpl.java:135)
at io.strimzi.controller.topic.zk.ZkImpl.lambda$children$10(ZkImpl.java:342)
at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:601)
at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:505)

{code}
 

 

Additional details:

Docker version: 18.02.0-ce

OpenShift server version: v3.7.1

  was:
 

Step to reproduce:
 # Clone and open Strimzi sources [https://github.com/strimzi/strimzi]
 # Up cluster **
{code:java}
$ oc clucter up{code}
**
 # Login as ** admin
{code:java}
$ oc login -u system:admin{code}

 # Deploy Cluster Controller
{code:java}
$ oc create -f resources/openshift/cluster-controller-with-template.yaml{code}

 # Deploy Topic Controller
{code:java}
$ oc create -f resources/openshift/topic-controller-with-template.yaml{code}

 # Login to OpenShift [https://127.0.0.1:8443|https://127.0.0.1:8443/]
 # Create "Apache Kafka (Ephemeral storage)"
 ## Click "Add to project"
 ## Click "Select from project"
 ## Select "Apache Kafka (Ephemeral storage)" and click "Next"
 ## Use default configurations:
 ### Number of Zookeper cluster nodes: 1
 ### Number of Kafka cluster nodes: 3
 ### Zookeeper healthcheck initial delay: 15
 ### Zookeeper healthcheck timeout: 5
 ## Click "Create" and wait for the message "Apache Kafka (Ephemeral storage) has been created"
 ## Open page "Pods" and wait when all pods will have status "Running"
 # Create Strimzi Topic Controller
 ## Click "Add to project"
 ## Click "Select from project"
 ## Select "Strimzi Topic Controller" and click "Next"
 ## Use default configurations
 ## Click "Create" and wait for the message "Success Strimzi Topic Controller has been created."
 ## Open page "Pods" and wait when all pods will have status "Running"
 # Open page "Config Maps" and open your cluster config
 # Edit value for zookeeper-healthcheck-delay
 ## Click "Actions"
 ## Click "Edit YAML"
 ## Set new value (30) for variable zookeeper-healthcheck-delay and save
 # Open page "Pods" and open logs for strimzi-topic-controller

Actual result:

Log has an unhandled exception:
{code:java}
[2018-02-21 15:48:18,807] WARN <ClientCnxn :1162> [.local:2181)] Session 0x161b8fedf870003 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.NoRouteToHostException: No route to host
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
Feb 21, 2018 3:48:18 PM io.vertx.core.impl.ContextImpl
SEVERE: Unhandled exception
java.lang.RuntimeException: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for for path: /brokers/topics
at io.strimzi.controller.topic.TopicsWatcher.lambda$start$2(TopicsWatcher.java:67)
at io.strimzi.controller.topic.zk.ZkImpl.lambda$null$9(ZkImpl.java:347)
at io.vertx.core.impl.ContextImpl.lambda$wrapTask$2(ContextImpl.java:344)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:403)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for for path: /brokers/topics
at org.apache.zookeeper.KeeperException.create(KeeperException.java:99)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
at io.strimzi.controller.topic.zk.ZkImpl.mapResult(ZkImpl.java:135)
at io.strimzi.controller.topic.zk.ZkImpl.lambda$children$10(ZkImpl.java:342)
at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:601)
at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:505)

{code}
 

 

Additional details:

Docker version: 18.02.0-ce

OpenShift server version: v3.7.1


> Unhandled exception "NoRouteToHostException: No route to host" 
> ---------------------------------------------------------------
>
>                 Key: KAFKA-6575
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6575
>             Project: Kafka
>          Issue Type: Bug
>         Environment: Fedora 27
>            Reporter: Sergey Romanov
>            Priority: Major
>
>  
> Step to reproduce:
>  # Clone and open Strimzi sources [https://github.com/strimzi/strimzi]
>  # Up cluster
> {code:java}
> $ oc clucter up{code}
>  # Login as admin
> {code:java}
> $ oc login -u system:admin{code}
>  # Deploy Cluster Controller
> {code:java}
> $ oc create -f resources/openshift/cluster-controller-with-template.yaml{code}
>  # Deploy Topic Controller
> {code:java}
> $ oc create -f resources/openshift/topic-controller-with-template.yaml{code}
>  # Login to OpenShift [https://127.0.0.1:8443|https://127.0.0.1:8443/]
>  # Create "Apache Kafka (Ephemeral storage)"
>  ## Click "Add to project"
>  ## Click "Select from project"
>  ## Select "Apache Kafka (Ephemeral storage)" and click "Next"
>  ## Use default configurations:
>  ### Number of Zookeper cluster nodes: 1
>  ### Number of Kafka cluster nodes: 3
>  ### Zookeeper healthcheck initial delay: 15
>  ### Zookeeper healthcheck timeout: 5
>  ## Click "Create" and wait for the message "Apache Kafka (Ephemeral storage) has been created"
>  ## Open page "Pods" and wait when all pods will have status "Running"
>  # Create Strimzi Topic Controller
>  ## Click "Add to project"
>  ## Click "Select from project"
>  ## Select "Strimzi Topic Controller" and click "Next"
>  ## Use default configurations
>  ## Click "Create" and wait for the message "Success Strimzi Topic Controller has been created."
>  ## Open page "Pods" and wait when all pods will have status "Running"
>  # Open page "Config Maps" and open your cluster config
>  # Edit value for zookeeper-healthcheck-delay
>  ## Click "Actions"
>  ## Click "Edit YAML"
>  ## Set new value (30) for variable zookeeper-healthcheck-delay and save
>  # Open page "Pods" and open logs for strimzi-topic-controller
> Actual result:
> Log has an unhandled exception:
> {code:java}
> [2018-02-21 15:48:18,807] WARN <ClientCnxn :1162> [.local:2181)] Session 0x161b8fedf870003 for server null, unexpected error, closing socket connection and attempting reconnect
> java.net.NoRouteToHostException: No route to host
> at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
> at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
> Feb 21, 2018 3:48:18 PM io.vertx.core.impl.ContextImpl
> SEVERE: Unhandled exception
> java.lang.RuntimeException: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for for path: /brokers/topics
> at io.strimzi.controller.topic.TopicsWatcher.lambda$start$2(TopicsWatcher.java:67)
> at io.strimzi.controller.topic.zk.ZkImpl.lambda$null$9(ZkImpl.java:347)
> at io.vertx.core.impl.ContextImpl.lambda$wrapTask$2(ContextImpl.java:344)
> at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
> at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:403)
> at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
> at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for for path: /brokers/topics
> at org.apache.zookeeper.KeeperException.create(KeeperException.java:99)
> at org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
> at io.strimzi.controller.topic.zk.ZkImpl.mapResult(ZkImpl.java:135)
> at io.strimzi.controller.topic.zk.ZkImpl.lambda$children$10(ZkImpl.java:342)
> at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:601)
> at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:505)
> {code}
>  
>  
> Additional details:
> Docker version: 18.02.0-ce
> OpenShift server version: v3.7.1



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