server.log

0    [main] WARN  com.mapr.franz.server.ClusterState  - connecting to localhost:2108
489  [main-EventThread] INFO  com.mapr.franz.server.ClusterState  - SyncConnected
987  [main] INFO  com.mapr.franz.server.ClusterState  - Server -3851085439804092173 reading from status directory /franz
1681 [main] INFO  com.mapr.franz.server.ClusterState  - Entries: [ca8e323248cc50f3], our file: ca8e323248cc50f3
1681 [main] INFO  com.mapr.franz.server.ClusterState  - Server -3851085439804092173 read 1 entries in status directory
1681 [main] INFO  com.mapr.franz.server.ClusterState  - Server -3851085439804092173 has position 0 
6964 [main] INFO  com.googlecode.protobuf.pro.duplex.RpcServiceRegistry  - Registered Blocking CatcherService allowTimeout=Y
18575 [New I/O  worker #1] DEBUG com.googlecode.protobuf.pro.duplex.handler.ServerConnectRequestHandler  - Received [2]ConnectRequest.
18579 [New I/O  worker #1] DEBUG com.googlecode.protobuf.pro.duplex.handler.ServerConnectRequestHandler  - Sending [2]ConnectResponse.
18591 [New I/O  worker #1] DEBUG com.mapr.franz.server.Server  - Connect with clientHostname:9999[0835aef8-8ab8-447f-b2d5-b1df6bd2b3bf]
18714 [New I/O  worker #1] DEBUG com.googlecode.protobuf.pro.duplex.RpcServer  - Received [1]RpcRequest.
18714 [New I/O  worker #1] DEBUG com.googlecode.protobuf.pro.duplex.RpcServiceRegistry  - Resolved CatcherService
18720 [rpc:pool-3-thread-1] DEBUG com.googlecode.protobuf.pro.duplex.RpcServer  - Sending [1]RpcResponse.
18797 [rpc:pool-3-thread-1] INFO  CatcherService.hello.info  - duration: 7 server: "serverHostname:8080[bb39536e-b175-413b-98c2-2ea4fcca72d3]" signature: "CatcherService.hello" client: "clientHostname:9999[0835aef8-8ab8-447f-b2d5-b1df6bd2b3bf]" corId: 1 request { ts: 1361328819132 size: 15 uuid: "fe5b3d1f-353e-4ca1-957b-1ebd466e3310" } response { ts: 1361328819139 size: 62 uuid: "e960fc26-220e-400d-ba8c-cb357ffd1525" }
18797 [rpc:pool-3-thread-1] INFO  CatcherService.hello.data.request  - uuid: "fe5b3d1f-353e-4ca1-957b-1ebd466e3310" content: "clientId: 1 application: \"test-client\""
18797 [rpc:pool-3-thread-1] INFO  CatcherService.hello.data.response  - uuid: "fe5b3d1f-353e-4ca1-957b-1ebd466e3310" content: "serverId: 14595658633905459443 host { hostName: \"192.168.1.81\" port: 9013 } cluster { serverId: 14595658633905459443 host { hostName: \"192.168.1.81\" port: 9013 } }"
18843 [New I/O  worker #1] DEBUG com.mapr.franz.server.Server  - Disconnect from clientHostname:9999[0835aef8-8ab8-447f-b2d5-b1df6bd2b3bf]

tweetlogger.log

13/02/19 21:53:38 INFO catcher.Client: Connecting to HostPort{host='127.0.0.1', port=8080}
13/02/19 21:53:38 INFO catcher.CatcherConnection: Connecting to 127.0.0.1:8080[7545003d-de94-4ec3-aa3e-ec646f8f28cf]
13/02/19 21:53:39 INFO catcher.Client: Connecting to HostPort{host='192.168.1.81', port=9013}
13/02/19 21:53:39 INFO catcher.CatcherConnection: Connecting to 192.168.1.81:9013[a8413dd9-e682-4c8a-b4f1-61796ccd576d]
13/02/19 21:53:39 WARN catcher.CatcherConnection: Cannot connect to 192.168.1.81:9013[a8413dd9-e682-4c8a-b4f1-61796ccd576d]
java.io.IOException: Failed to connect to /192.168.1.81:9013
  at com.googlecode.protobuf.pro.duplex.client.DuplexTcpClientBootstrap.peerWith(DuplexTcpClientBootstrap.java:139)
	at com.googlecode.protobuf.pro.duplex.client.DuplexTcpClientBootstrap.peerWith(DuplexTcpClientBootstrap.java:106)
	at com.mapr.franz.catcher.CatcherConnection.<init>(CatcherConnection.java:55)
	at com.mapr.franz.catcher.CatcherConnection.connect(CatcherConnection.java:31)
	at com.mapr.franz.catcher.ConnectionFactory.create(ConnectionFactory.java:10)
	at com.mapr.franz.catcher.Client.connectAll(Client.java:306)
	at com.mapr.franz.catcher.Client.<init>(Client.java:104)
	at com.mapr.franz.catcher.Client.<init>(Client.java:97)
	at com.mapr.demo.twitter.TweetLogger.query(TweetLogger.java:34)
	at com.mapr.demo.twitter.TweetLogger.main(TweetLogger.java:27)
Caused by: java.net.ConnectException: Connection refused
	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599)
	at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:496)
	at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:452)
	at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:365)
	at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
	at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
	at java.lang.Thread.run(Thread.java:680)
13/02/19 21:53:39 WARN handler.ClientConnectResponseHandler: Exception caught during RPC connection handshake.
java.net.ConnectException: Connection refused
	at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
	at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599)
	at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.connect(NioClientSocketPipelineSink.java:496)
	at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.processSelectedKeys(NioClientSocketPipelineSink.java:452)
	at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink$Boss.run(NioClientSocketPipelineSink.java:365)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
	at java.lang.Thread.run(Thread.java:680)
13/02/19 21:53:39 WARN catcher.Client: Cannot connect to HostPort{host='192.168.1.81', port=9013}