I believe so. Happy to be corrected. On Wed, Feb 17, 2016 at 12:31 PM, Joe San <codeintheo...@gmail.com> wrote:
> So if I use the High Level Consumer API, using the ConsumerConnector, I get > this automatic zookeeper connection for free? > > On Wed, Feb 17, 2016 at 8:25 PM, Christian Posta < > christian.po...@gmail.com> > wrote: > > > i believe reconnect is handled automatically by the client... is that > what > > you're asking > > peek here to see how it does that and when: > > > > > > > https://github.com/apache/zookeeper/blob/trunk/src/java/main/org/apache/zookeeper/ClientCnxn.java#L1153 > > > > On Wed, Feb 17, 2016 at 12:14 PM, Joe San <codeintheo...@gmail.com> > wrote: > > > > > 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 > > > > > > > > > > > > > > > -- > > *Christian Posta* > > twitter: @christianposta > > http://www.christianposta.com/blog > > http://fabric8.io > > > -- *Christian Posta* twitter: @christianposta http://www.christianposta.com/blog http://fabric8.io
