Re: Zookeeper Error
Just a heads up. Windows doesn’t cleanup logs. There’s a pull req pending for issue #1194. Regards, On Mon, 19 Feb 2018 at 09:14, Maria Pilar wrote: > Now It´s working properly, I have changed the server.id in to the > zookeeper. properties and I have created topics into mutinode. > > I´m using windows because it´s a simple proof of concept. > > Thanks > > On 18 February 2018 at 03:15, Ted Yu wrote: > > > What are the entries in /etc/hosts w.r.t. localhost ? > > > > I wonder if the exception had something to do with ipv6. > > > > On Sat, Feb 17, 2018 at 5:49 PM, Maria Pilar > wrote: > > > > > When i try to create a topic in that multicluster, > > > > > > kafka-topics.bat --create --topic my-kafka-topic --zookeeper > > locahost:2181 > > > --replication-factor 2 --partitions 3 > > > > > > > > > i have received the same error > > > > > > Exception in thread "main" org.I0Itec.zkclient.exception.ZkException: > > > Unable to connect to locahost:2181 > > > at org.I0Itec.zkclient.ZkConnection.connect( > > ZkConnection.java:72) > > > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228) > > > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157) > > > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131) > > > at > > > kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:115) > > > at kafka.utils.ZkUtils$.apply(ZkUtils.scala:97) > > > at kafka.admin.TopicCommand$.main(TopicCommand.scala:56) > > > at kafka.admin.TopicCommand.main(TopicCommand.scala) > > > Caused by: java.net.UnknownHostException: locahost > > > 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.( > > > StaticHostProvider.java:61) > > > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:445) > > > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:380) > > > at org.I0Itec.zkclient.ZkConnection.connect( > > ZkConnection.java:70) > > > ... 7 more > > > > > > Thanks > > > > > > On 18 February 2018 at 02:45, Maria Pilar wrote: > > > > > > > Hi > > > > > > > > I´m trying to configure a multinode cluster in kafka. I have > configured > > > > each server.properties according with the new properties for each > > server. > > > > > > > > When i start each server, the zookeeper console shows that error. > > > > > > > > INFO Got user-level KeeperException when processing > > > > sessionid:0x161a690f731 type:create cxid:0xd8 zxid:0x11f > txntype:-1 > > > > reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = > NodeExists > > > for > > > > /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor) > > > > > > > > I have configured each broker.id > > > > > > > > > > > > Anybody knows what is the error? > > > > > > > > Thanks > > > > > > > > > >
Re: Zookeeper Error
Yes, I made a spelling mistake. I have changed it. Thanks On 18 February 2018 at 11:49, Gerd König wrote: > Hi, > > in your message there is "locahost", but I am pretty sure you wanted to use > "localhost", including the "l", right? > This one will usually be resolvable, hence doesn't throw an > unknownHostException > > Regards > > Maria Pilar schrieb am So., 18. Feb. 2018, 02:49: > > > When i try to create a topic in that multicluster, > > > > kafka-topics.bat --create --topic my-kafka-topic --zookeeper > locahost:2181 > > --replication-factor 2 --partitions 3 > > > > > > i have received the same error > > > > Exception in thread "main" org.I0Itec.zkclient.exception.ZkException: > > Unable to connect to locahost:2181 > > at org.I0Itec.zkclient.ZkConnection.connect( > ZkConnection.java:72) > > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228) > > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157) > > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131) > > at > > kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:115) > > at kafka.utils.ZkUtils$.apply(ZkUtils.scala:97) > > at kafka.admin.TopicCommand$.main(TopicCommand.scala:56) > > at kafka.admin.TopicCommand.main(TopicCommand.scala) > > Caused by: java.net.UnknownHostException: locahost > > 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.( > StaticHostProvider.java:61) > > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:445) > > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:380) > > at org.I0Itec.zkclient.ZkConnection.connect( > ZkConnection.java:70) > > ... 7 more > > > > Thanks > > > > On 18 February 2018 at 02:45, Maria Pilar wrote: > > > > > Hi > > > > > > I´m trying to configure a multinode cluster in kafka. I have configured > > > each server.properties according with the new properties for each > server. > > > > > > When i start each server, the zookeeper console shows that error. > > > > > > INFO Got user-level KeeperException when processing > > > sessionid:0x161a690f731 type:create cxid:0xd8 zxid:0x11f txntype:-1 > > > reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists > > for > > > /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor) > > > > > > I have configured each broker.id > > > > > > > > > Anybody knows what is the error? > > > > > > Thanks > > > > > >
Re: Zookeeper Error
Now It´s working properly, I have changed the server.id in to the zookeeper. properties and I have created topics into mutinode. I´m using windows because it´s a simple proof of concept. Thanks On 18 February 2018 at 03:15, Ted Yu wrote: > What are the entries in /etc/hosts w.r.t. localhost ? > > I wonder if the exception had something to do with ipv6. > > On Sat, Feb 17, 2018 at 5:49 PM, Maria Pilar wrote: > > > When i try to create a topic in that multicluster, > > > > kafka-topics.bat --create --topic my-kafka-topic --zookeeper > locahost:2181 > > --replication-factor 2 --partitions 3 > > > > > > i have received the same error > > > > Exception in thread "main" org.I0Itec.zkclient.exception.ZkException: > > Unable to connect to locahost:2181 > > at org.I0Itec.zkclient.ZkConnection.connect( > ZkConnection.java:72) > > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228) > > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157) > > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131) > > at > > kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:115) > > at kafka.utils.ZkUtils$.apply(ZkUtils.scala:97) > > at kafka.admin.TopicCommand$.main(TopicCommand.scala:56) > > at kafka.admin.TopicCommand.main(TopicCommand.scala) > > Caused by: java.net.UnknownHostException: locahost > > 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.( > > StaticHostProvider.java:61) > > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:445) > > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:380) > > at org.I0Itec.zkclient.ZkConnection.connect( > ZkConnection.java:70) > > ... 7 more > > > > Thanks > > > > On 18 February 2018 at 02:45, Maria Pilar wrote: > > > > > Hi > > > > > > I´m trying to configure a multinode cluster in kafka. I have configured > > > each server.properties according with the new properties for each > server. > > > > > > When i start each server, the zookeeper console shows that error. > > > > > > INFO Got user-level KeeperException when processing > > > sessionid:0x161a690f731 type:create cxid:0xd8 zxid:0x11f txntype:-1 > > > reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists > > for > > > /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor) > > > > > > I have configured each broker.id > > > > > > > > > Anybody knows what is the error? > > > > > > Thanks > > > > > >
Re: Zookeeper Error
Hi, in your message there is "locahost", but I am pretty sure you wanted to use "localhost", including the "l", right? This one will usually be resolvable, hence doesn't throw an unknownHostException Regards Maria Pilar schrieb am So., 18. Feb. 2018, 02:49: > When i try to create a topic in that multicluster, > > kafka-topics.bat --create --topic my-kafka-topic --zookeeper locahost:2181 > --replication-factor 2 --partitions 3 > > > i have received the same error > > Exception in thread "main" org.I0Itec.zkclient.exception.ZkException: > Unable to connect to locahost:2181 > at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:72) > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228) > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157) > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131) > at > kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:115) > at kafka.utils.ZkUtils$.apply(ZkUtils.scala:97) > at kafka.admin.TopicCommand$.main(TopicCommand.scala:56) > at kafka.admin.TopicCommand.main(TopicCommand.scala) > Caused by: java.net.UnknownHostException: locahost > 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.(StaticHostProvider.java:61) > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:445) > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:380) > at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:70) > ... 7 more > > Thanks > > On 18 February 2018 at 02:45, Maria Pilar wrote: > > > Hi > > > > I´m trying to configure a multinode cluster in kafka. I have configured > > each server.properties according with the new properties for each server. > > > > When i start each server, the zookeeper console shows that error. > > > > INFO Got user-level KeeperException when processing > > sessionid:0x161a690f731 type:create cxid:0xd8 zxid:0x11f txntype:-1 > > reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists > for > > /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor) > > > > I have configured each broker.id > > > > > > Anybody knows what is the error? > > > > Thanks > > >
Re: Zookeeper Error
Yes, i have included the server.id into zookeeper.properties and it´s working fine. Thanks On 18 February 2018 at 03:15, Ted Yu wrote: > What are the entries in /etc/hosts w.r.t. localhost ? > > I wonder if the exception had something to do with ipv6. > > On Sat, Feb 17, 2018 at 5:49 PM, Maria Pilar wrote: > > > When i try to create a topic in that multicluster, > > > > kafka-topics.bat --create --topic my-kafka-topic --zookeeper > locahost:2181 > > --replication-factor 2 --partitions 3 > > > > > > i have received the same error > > > > Exception in thread "main" org.I0Itec.zkclient.exception.ZkException: > > Unable to connect to locahost:2181 > > at org.I0Itec.zkclient.ZkConnection.connect( > ZkConnection.java:72) > > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228) > > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157) > > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131) > > at > > kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:115) > > at kafka.utils.ZkUtils$.apply(ZkUtils.scala:97) > > at kafka.admin.TopicCommand$.main(TopicCommand.scala:56) > > at kafka.admin.TopicCommand.main(TopicCommand.scala) > > Caused by: java.net.UnknownHostException: locahost > > 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.( > > StaticHostProvider.java:61) > > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:445) > > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:380) > > at org.I0Itec.zkclient.ZkConnection.connect( > ZkConnection.java:70) > > ... 7 more > > > > Thanks > > > > On 18 February 2018 at 02:45, Maria Pilar wrote: > > > > > Hi > > > > > > I´m trying to configure a multinode cluster in kafka. I have configured > > > each server.properties according with the new properties for each > server. > > > > > > When i start each server, the zookeeper console shows that error. > > > > > > INFO Got user-level KeeperException when processing > > > sessionid:0x161a690f731 type:create cxid:0xd8 zxid:0x11f txntype:-1 > > > reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists > > for > > > /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor) > > > > > > I have configured each broker.id > > > > > > > > > Anybody knows what is the error? > > > > > > Thanks > > > > > >
Re: Zookeeper Error
What are the entries in /etc/hosts w.r.t. localhost ? I wonder if the exception had something to do with ipv6. On Sat, Feb 17, 2018 at 5:49 PM, Maria Pilar wrote: > When i try to create a topic in that multicluster, > > kafka-topics.bat --create --topic my-kafka-topic --zookeeper locahost:2181 > --replication-factor 2 --partitions 3 > > > i have received the same error > > Exception in thread "main" org.I0Itec.zkclient.exception.ZkException: > Unable to connect to locahost:2181 > at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:72) > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228) > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157) > at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131) > at > kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:115) > at kafka.utils.ZkUtils$.apply(ZkUtils.scala:97) > at kafka.admin.TopicCommand$.main(TopicCommand.scala:56) > at kafka.admin.TopicCommand.main(TopicCommand.scala) > Caused by: java.net.UnknownHostException: locahost > 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.( > StaticHostProvider.java:61) > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:445) > at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:380) > at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:70) > ... 7 more > > Thanks > > On 18 February 2018 at 02:45, Maria Pilar wrote: > > > Hi > > > > I´m trying to configure a multinode cluster in kafka. I have configured > > each server.properties according with the new properties for each server. > > > > When i start each server, the zookeeper console shows that error. > > > > INFO Got user-level KeeperException when processing > > sessionid:0x161a690f731 type:create cxid:0xd8 zxid:0x11f txntype:-1 > > reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists > for > > /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor) > > > > I have configured each broker.id > > > > > > Anybody knows what is the error? > > > > Thanks > > >
Re: Zookeeper Error
When i try to create a topic in that multicluster, kafka-topics.bat --create --topic my-kafka-topic --zookeeper locahost:2181 --replication-factor 2 --partitions 3 i have received the same error Exception in thread "main" org.I0Itec.zkclient.exception.ZkException: Unable to connect to locahost:2181 at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:72) at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228) at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157) at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131) at kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:115) at kafka.utils.ZkUtils$.apply(ZkUtils.scala:97) at kafka.admin.TopicCommand$.main(TopicCommand.scala:56) at kafka.admin.TopicCommand.main(TopicCommand.scala) Caused by: java.net.UnknownHostException: locahost 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.(StaticHostProvider.java:61) at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:445) at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:380) at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:70) ... 7 more Thanks On 18 February 2018 at 02:45, Maria Pilar wrote: > Hi > > I´m trying to configure a multinode cluster in kafka. I have configured > each server.properties according with the new properties for each server. > > When i start each server, the zookeeper console shows that error. > > INFO Got user-level KeeperException when processing > sessionid:0x161a690f731 type:create cxid:0xd8 zxid:0x11f txntype:-1 > reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists for > /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor) > > I have configured each broker.id > > > Anybody knows what is the error? > > Thanks >