It is all pretty strange. Here is what I see in my logs as soon as I voluntarily shutdown Zookeeper!
java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_60] at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[na:1.8.0_60] at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361) ~[zookeeper-3.4.6.jar:3.4.6-1569965] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081) ~[zookeeper-3.4.6.jar:3.4.6-1569965] 20160217-20:12:44.960+0100 [sally-kafka-consumer-akka.actor.default-dispatcher-4-SendThread( 127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server 127.0.0.1/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) 20160217-20:12:44.960+0100 [sally-kafka-consumer-akka.actor.default-dispatcher-4-SendThread( 127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - Session 0x152ea19656b005c for server null, unexpected error, closing socket connection and attempting reconnect java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_60] at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[na:1.8.0_60] at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361) ~[zookeeper-3.4.6.jar:3.4.6-1569965] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081) ~[zookeeper-3.4.6.jar:3.4.6-1569965] It just keep repeating trying to reconnect for ever! So I just wanted to know which property from my setting in my email above is responsible for this auto reconnect mechanism? On Wed, Feb 17, 2016 at 8:04 PM, Christian Posta <christian.po...@gmail.com> wrote: > Yep, assuming you haven't completely partitioned that client from the > cluster, ZK should automatically try to connect/reconnect to other peers in > the server list. Otherwise, it's as Alexis said -- your session would > expire; you'd have to recreate the session once you have connectivity > > On Wed, Feb 17, 2016 at 2:30 AM, Alexis Midon < > alexis.mi...@airbnb.com.invalid> wrote: > > > By "re-connect", I'm assuming that the ZK session is expired, not > > disconnected. > > For details see > > > > > http://zookeeper.apache.org/doc/trunk/zookeeperProgrammers.html#ch_zkSessions > > > > In that case, the high level consumer is basically dead, and the > > application should create a new instance of it. > > > > > > On Mon, Feb 15, 2016 at 12:22 PM Joe San <codeintheo...@gmail.com> > wrote: > > > > > Any ideas as to which property should I set to enable Zookeeper > > > re-connection? I have the following properties defined for my consumer > > > (High Level Consumer API). Is this enough for a automatic Zookeeper > > > re-connect? > > > > > > val props = new Properties() > > > props.put("zookeeper.connect", zookeeper) > > > props.put("group.id", groupId) > > > props.put("auto.commit.enabled", "false") > > > // this timeout is needed so that we do not block on the stream! > > > props.put("consumer.timeout.ms", "1") > > > props.put("zookeeper.sync.time.ms", "200") > > > > > > > > > -- > *Christian Posta* > twitter: @christianposta > http://www.christianposta.com/blog > http://fabric8.io >
