These are ZK warnings. It seems to be related to the SASL setting. Thanks,
Jun On Tue, Feb 11, 2014 at 2:46 AM, Laurent Thoulon < laurent.thou...@ldmobile.net> wrote: > > Hi, > > I'm working with a kafka producer in async mode using zookeeper. > From time to time, i observe network problems and i see the following > error in my logs: > > [2014-02-11 11:21:57,848][INFO ][org.apache.zookeeper.ClientCnxn] Unable > to read additional data from server sessionid 0x1441cc4a9c5001f, likely > server has closed socket, closing socket connection and attempting reconnect > [2014-02-11 11:21:57,949][INFO ][org.I0Itec.zkclient.ZkClient] zookeeper > state changed (Disconnected) > [2014-02-11 11:21:59,143][INFO ][org.apache.zookeeper.ClientCnxn] Opening > socket connection to server obfuscated . Will not attempt to authenticate > using SASL (unknown error) > [2014-02-11 11:21:59,146][WARN ][org.apache.zookeeper.ClientCnxn] Session > 0x1441cc4a9c5001f for server null, unexpected error, closing socket > connection and attempting reconnect > java.net.ConnectException: Connection refused > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) > at > org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) > at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1068) > > The problem is, my code isn't catching this error and i haven't found > anyway to do so. > I thought about using the CallbackHandler but it doesn't have any onError > method. > > Is there anyway to trigger some process when connection fails ? > What i would like to do is to put my trafic on hold when this happens and > until the connection is back up so i'm sure each incoming request that > succeeds is logged into kafka. > > FYI, I'm not using the synchronized producer for performance issues. > > Thanks for your help on this matter. > > Laurent >
