Issue

• User is trying to create external TOPIC subscriber as standalone java client.
• But always get the following error and can't set listener.

        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1068)
17:13:08 INFO  Opening socket connection to server HOSTNAME/IP:2181. Will not attempt to authenticate using SASL (unknown error)
17:13:09 INFO  Socket connection established to HOSTNAME/IP:2181, initiating session
17:13:09 INFO  Session establishment complete on server HOSTNAME/IP:2181, sessionid = 0x14ddd8c6950004d, negotiated timeout = 40000
17:13:09 INFO  State change: CONNECTED
17:13:09 WARN  There are no ConnectionStateListeners registered.
17:13:09 INFO  ****** connection start
17:13:11 INFO  Adding new broker connection URL: tcp://HOSTNAME:49044
17:13:12 INFO  Successfully connected to tcp://HOSTNAME:49044
17:13:12 INFO  ****** session: ActiveMQSession {id=ID:xyz-1:1:1,started=false}
17:13:12 INFO  ****** receiver ActiveMQMessageConsumer { value=ID:xyz-1:1:1:1, started=false }
17:13:12 WARN  Transport (tcp://HOSTNAME/IP:49044@54580) failed, reason:  , attempting to automatically reconnect
java.io.EOFException
        at java.io.DataInputStream.readInt(DataInputStream.java:392)
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258)
        at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221)
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
        at java.lang.Thread.run(Thread.java:745)
17:13:12 INFO  Successfully reconnected to tcp://HOSTNAME:49044
17:13:13 INFO  Session: 0x14ddd8c6950004d closed

• Broker is created following way

mq-create --create-container br --replicas 2 --group mq-master-slave-group  example-broker 

• Is there something missing in code ?