You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by "M. Manna" <ma...@gmail.com> on 2017/07/07 08:59:47 UTC
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,
Re: 答复: console consumer doesn't recognise localhost:2181 but only 127.0.0.1:2181
Posted by "M. Manna" <ma...@gmail.com>.
Yes sorry that was the reason . Thanks for pointing that out :)
On 7 July 2017 at 10:03, Hu Xi <hu...@hotmail.com> wrote:
> “Caused by: java.net.UnknownHostException: localhsot" ----- localhsot? A
> typo?
>
>
> ________________________________
> 发件人: M. Manna <ma...@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,
>
答复: console consumer doesn't recognise localhost:2181 but only 127.0.0.1:2181
Posted by Hu Xi <hu...@hotmail.com>.
“Caused by: java.net.UnknownHostException: localhsot" ----- localhsot? A typo?
________________________________
发件人: M. Manna <ma...@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,