Re: Zookeeper Error

[M. Manna]

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

[Maria Pilar]

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

[Maria Pilar]

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

[Gerd König]

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

[Maria Pilar]

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

[Ted Yu]

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

[Maria Pilar]

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
>