Yes sorry that was the reason . Thanks for pointing that out :)
On 7 July 2017 at 10:03, Hu Xi <huxi...@hotmail.com> wrote: > “Caused by: java.net.UnknownHostException: localhsot" ----- localhsot? A > typo? > > > ________________________________ > 发件人: M. Manna <manme...@gmail.com> > 发送时间: 2017年7月7日 16:59 > 收件人: users@kafka.apache.org > 主题: console consumer doesn't recognise localhost:2181 but only > 127.0.0.1:2181 > > Hello, > > As part of my PoC I wanted to check if we have two Windows 10 boxes where > > 1) One box will have the ZK > 2) Other box will have Kafka > > The idea was to physically separate zookeeper and Kafka to isolate issues. > For trial, I set it up on my Windows 10 machine where I used the > Documentation to create 3 ZK and 3 Kafka cluster setup. For this, I > downloaded zookeeper-3.4.10 separately, and started them (in order) and > independent of Kafka Servers. So I am* not *using zookeeper-server-start. > > When I ran the topics utility > > C:/kafka/bin/windows/kafka-topics --create --topic "test1" --partitions 3 > --replication-factor 3 --zookeeper > localhost:2181,localhost:2182,localhost:2183 > > It spits out error since it cannot find localhost: > > C:\kafka_2.10-0.10.2.1\bin\windows>kafka-topics.bat --create --topic test1 > > --zookeeper localhsot:2181,localhost:2182,localhost:2183 --partitions 3 > > --replication-factor 3 > > Exception in thread "main" org.I0Itec.zkclient.exception.ZkException: > > Unable to connect to localhsot:2181,localhost:2182,localhost:2183 > > at org.I0Itec.zkclient.ZkConnection.connect( > ZkConnection.java:72) > > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228) > > at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:157) > > at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:131) > > at > > kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:106) > > at kafka.utils.ZkUtils$.apply(ZkUtils.scala:88) > > at kafka.admin.TopicCommand$.main(TopicCommand.scala:53) > > at kafka.admin.TopicCommand.main(TopicCommand.scala) > > Caused by: java.net.UnknownHostException: localhsot > > at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method) > > at java.net.InetAddress$2.lookupAllHostAddr(InetAddress. > java:928) > > at > > java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1323) > > at java.net.InetAddress.getAllByName0(InetAddress.java:1276) > > at java.net.InetAddress.getAllByName(InetAddress.java:1192) > > at java.net.InetAddress.getAllByName(InetAddress.java:1126) > > at > > org.apache.zookeeper.client.StaticHostProvider.<init>( > StaticHostProvider.java:61) > > at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:445) > > at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:380) > > at org.I0Itec.zkclient.ZkConnection.connect( > ZkConnection.java:70) > > ... 7 more > > > but when I replace them with 127.0.0.1 it works! I know that I have to keep > correct values for advertised.listeners or listeners property to make this > work correctly (and i have). But since it's ignoring "localhost" name when > zookeeper is started I am thinking that for some reason it couldn't bind > 127.0.0.1 to localhost. > > Has anyone experienced this with fully segregated ZK and Kafka setup? or is > it just Windows issue? > > KR, >
