[2014-11-05 10:31:12,414] DEBUG Got notification sessionid:0x14980b08c110003 (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,415] DEBUG Got WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/brokers/topics for sessionid 0x14980b08c110003 (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,415] DEBUG Received event: WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/brokers/topics (org.I0Itec.zkclient.ZkClient)
[2014-11-05 10:31:12,415] DEBUG New event: ZkEvent[Children of /brokers/topics changed sent to kafka.controller.PartitionStateMachine$TopicChangeListener@1fc5681] (org.I0Itec.zkclient.ZkEventThread)
[2014-11-05 10:31:12,415] DEBUG Leaving process event (org.I0Itec.zkclient.ZkClient)
[2014-11-05 10:31:12,415] DEBUG Delivering event #3 ZkEvent[Children of /brokers/topics changed sent to kafka.controller.PartitionStateMachine$TopicChangeListener@1fc5681] (org.I0Itec.zkclient.ZkEventThread)
[2014-11-05 10:31:12,415] DEBUG Got ping response for sessionid: 0x14980b08c110003 after 0ms (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,416] DEBUG Reading reply sessionid:0x14980b08c110003, packet:: clientPath:null serverPath:null finished:false header:: 257,3  replyHeader:: 257,13610,0  request:: '/brokers/topics,T  response:: s{6,6,1415130748279,1415130748279,0,23,0,0,0,23,13610}  (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,417] DEBUG Reading reply sessionid:0x14980b08c110003, packet:: clientPath:null serverPath:null finished:false header:: 258,8  replyHeader:: 258,13610,0  request:: '/brokers/topics,T  response:: v{'topic_23,'topic_18,'topic_22,'topic_17,'topic_25,'topic_16,'topic_24,'topic_15,'topic_14,'topic_13,'topic_12,'topic_11,'topic_19,'topic_5,'topic_7,'topic_6,'Test1,'topic_10,'topic_9,'topic_8,'topic_20,'topic_30,'topic_21}  (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,420] DEBUG Reading reply sessionid:0x14980b08c110003, packet:: clientPath:null serverPath:null finished:false header:: 259,4  replyHeader:: 259,13610,0  request:: '/brokers/topics/topic_30,F  response:: #7b2276657273696f6e223a312c22706172746974696f6e73223a7b2230223a5b305d7d7d,s{13610,13610,1415205072414,1415205072414,0,0,0,0,36,0,13610}  (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,422] DEBUG Replicas assigned to topic [topic_30], partition [0] are [List(0)] (kafka.utils.ZkUtils$)
[2014-11-05 10:31:12,422] DEBUG Replicas assigned to topic [topic_30], partition [0] are [List(0)] (kafka.utils.ZkUtils$)
[2014-11-05 10:31:12,425] DEBUG Reading reply sessionid:0x14980b08c110003, packet:: clientPath:null serverPath:null finished:false header:: 260,3  replyHeader:: 260,13611,0  request:: '/brokers/topics/topic_30,T  response:: s{13610,13610,1415205072414,1415205072414,0,0,0,0,36,0,13610}  (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,425] DEBUG Subscribed data changes for /brokers/topics/topic_30 (org.I0Itec.zkclient.ZkClient)
[2014-11-05 10:31:12,427] DEBUG Reading reply sessionid:0x14980b08c110003, packet:: clientPath:null serverPath:null finished:false header:: 261,4  replyHeader:: 261,13611,0  request:: '/brokers/topics/topic_30,T  response:: #7b2276657273696f6e223a312c22706172746974696f6e73223a7b2230223a5b305d7d7d,s{13610,13610,1415205072414,1415205072414,0,0,0,0,36,0,13610}  (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,430] DEBUG Reading reply sessionid:0x14980b08c110003, packet:: clientPath:null serverPath:null finished:false header:: 262,4  replyHeader:: 262,13611,-101  request:: '/brokers/topics/topic_30/partitions/0/state,F  response::   (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,434] DEBUG Reading reply sessionid:0x14980b08c110003, packet:: clientPath:null serverPath:null finished:false header:: 263,1  replyHeader:: 263,13612,-101  request:: '/brokers/topics/topic_30/partitions/0/state,#7b22636f6e74726f6c6c65725f65706f6368223a372c226c6561646572223a302c2276657273696f6e223a312c226c65616465725f65706f6368223a302c22697372223a5b305d7d,v{s{31,s{'world,'anyone}}},0  response::   (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,435] DEBUG Reading reply sessionid:0x14980b08c110003, packet:: clientPath:null serverPath:null finished:false header:: 264,1  replyHeader:: 264,13613,-101  request:: '/brokers/topics/topic_30/partitions/0,,v{s{31,s{'world,'anyone}}},0  response::   (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,437] DEBUG Reading reply sessionid:0x14980b08c110003, packet:: clientPath:null serverPath:null finished:false header:: 265,1  replyHeader:: 265,13614,0  request:: '/brokers/topics/topic_30/partitions,,v{s{31,s{'world,'anyone}}},0  response:: '/brokers/topics/topic_30/partitions  (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,438] DEBUG Reading reply sessionid:0x14980b08c110003, packet:: clientPath:null serverPath:null finished:false header:: 266,1  replyHeader:: 266,13615,0  request:: '/brokers/topics/topic_30/partitions/0,,v{s{31,s{'world,'anyone}}},0  response:: '/brokers/topics/topic_30/partitions/0  (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,439] DEBUG Reading reply sessionid:0x14980b08c110003, packet:: clientPath:null serverPath:null finished:false header:: 267,1  replyHeader:: 267,13616,0  request:: '/brokers/topics/topic_30/partitions/0/state,#7b22636f6e74726f6c6c65725f65706f6368223a372c226c6561646572223a302c2276657273696f6e223a312c226c65616465725f65706f6368223a302c22697372223a5b305d7d,v{s{31,s{'world,'anyone}}},0  response:: '/brokers/topics/topic_30/partitions/0/state  (org.apache.zookeeper.ClientCnxn)
[2014-11-05 10:31:12,440] TRACE 131 bytes written. (kafka.network.BoundedByteBufferSend)
[2014-11-05 10:31:12,440] TRACE 131 bytes written. (kafka.network.BoundedByteBufferSend)
[2014-11-05 10:31:12,441] DEBUG Delivering event #3 done (org.I0Itec.zkclient.ZkEventThread)
[2014-11-05 10:31:12,448] DEBUG Created socket with SO_TIMEOUT = 90000 (requested 90000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 84580 (requested -1). (kafka.network.BlockingChannel)
[2014-11-05 10:31:12,448] DEBUG Created socket with SO_TIMEOUT = 90000 (requested 90000), SO_RCVBUF = 43690 (requested -1), SO_SNDBUF = 84580 (requested -1). (kafka.network.BlockingChannel)
[2014-11-05 10:31:12,448] DEBUG Accepted connection from /127.0.0.1 on /127.0.0.1:9092. sendBufferSize [actual|requested]: [102400|102400] recvBufferSize [actual|requested]: [102400|102400] (kafka.network.Acceptor)
[2014-11-05 10:31:12,448] DEBUG Accepted connection from /127.0.0.1 on /127.0.0.1:9092. sendBufferSize [actual|requested]: [102400|102400] recvBufferSize [actual|requested]: [102400|102400] (kafka.network.Acceptor)
[2014-11-05 10:31:12,449] TRACE Processor id 1 selection time = 228708013 ns (kafka.network.Processor)
[2014-11-05 10:31:12,449] TRACE Processor id 1 selection time = 228708013 ns (kafka.network.Processor)
[2014-11-05 10:31:12,449] DEBUG Processor 1 listening to new connection from /127.0.0.1:55693 (kafka.network.Processor)
[2014-11-05 10:31:12,449] DEBUG Processor 1 listening to new connection from /127.0.0.1:55693 (kafka.network.Processor)