[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) [2014-11-05 10:31:12,550] TRACE Processor id 7 selection time = 301161349 ns (kafka.network.Processor) [2014-11-05 10:31:12,550] TRACE Processor id 7 selection time = 301161349 ns (kafka.network.Processor) [2014-11-05 10:31:12,596] TRACE Processor id 3 selection time = 300772884 ns (kafka.network.Processor) [2014-11-05 10:31:12,596] TRACE Processor id 3 selection time = 300772884 ns (kafka.network.Processor) [2014-11-05 10:31:12,640] TRACE Processor id 6 selection time = 301205873 ns (kafka.network.Processor) [2014-11-05 10:31:12,640] TRACE Processor id 6 selection time = 301205873 ns (kafka.network.Processor) [2014-11-05 10:31:12,660] TRACE Processor id 8 selection time = 301212710 ns (kafka.network.Processor) [2014-11-05 10:31:12,660] TRACE Processor id 8 selection time = 301212710 ns (kafka.network.Processor) [2014-11-05 10:31:12,660] TRACE Processor id 9 selection time = 301187091 ns (kafka.network.Processor) [2014-11-05 10:31:12,660] TRACE Processor id 9 selection time = 301187091 ns (kafka.network.Processor) [2014-11-05 10:31:12,673] TRACE Processor id 0 selection time = 301144174 ns (kafka.network.Processor) [2014-11-05 10:31:12,673] TRACE Processor id 0 selection time = 301144174 ns (kafka.network.Processor) [2014-11-05 10:31:12,674] TRACE Processor id 4 selection time = 301200540 ns (kafka.network.Processor) [2014-11-05 10:31:12,674] TRACE Processor id 4 selection time = 301200540 ns (kafka.network.Processor) [2014-11-05 10:31:12,675] TRACE Processor id 2 selection time = 301240208 ns (kafka.network.Processor) [2014-11-05 10:31:12,675] TRACE Processor id 2 selection time = 301240208 ns (kafka.network.Processor) [2014-11-05 10:31:12,679] TRACE Processor id 5 selection time = 301217390 ns (kafka.network.Processor) [2014-11-05 10:31:12,679] TRACE Processor id 5 selection time = 301217390 ns (kafka.network.Processor) [2014-11-05 10:31:12,750] TRACE Processor id 1 selection time = 300491401 ns (kafka.network.Processor) [2014-11-05 10:31:12,750] TRACE Processor id 1 selection time = 300491401 ns (kafka.network.Processor) [2014-11-05 10:31:12,750] TRACE 176 bytes written. (kafka.network.BoundedByteBufferSend) [2014-11-05 10:31:12,750] TRACE 176 bytes written. (kafka.network.BoundedByteBufferSend) [2014-11-05 10:31:12,750] TRACE Processor id 1 selection time = 232897 ns (kafka.network.Processor) [2014-11-05 10:31:12,750] TRACE Processor id 1 selection time = 232897 ns (kafka.network.Processor) [2014-11-05 10:31:12,750] TRACE 172 bytes read from /127.0.0.1:55693 (kafka.network.Processor) [2014-11-05 10:31:12,750] TRACE 172 bytes read from /127.0.0.1:55693 (kafka.network.Processor) [2014-11-05 10:31:12,751] TRACE [Kafka Request Handler 2 on Broker 0], Kafka request handler 2 on broker 0 handling request Request(1,sun.nio.ch.SelectionKeyImpl@3a6a2cf,null,1415205072751,/127.0.0.1:55693) (kafka.server.KafkaRequestHandler) [2014-11-05 10:31:12,751] TRACE [Kafka Request Handler 2 on Broker 0], Kafka request handler 2 on broker 0 handling request Request(1,sun.nio.ch.SelectionKeyImpl@3a6a2cf,null,1415205072751,/127.0.0.1:55693) (kafka.server.KafkaRequestHandler) [2014-11-05 10:31:12,751] TRACE [KafkaApi-0] Handling request: Name:UpdateMetadataRequest;Version:0;Controller:0;ControllerEpoch:7;CorrelationId:8;ClientId:id_0-host_null-port_9092;AliveBrokers:id:0,host:localhost.localdomain,port:9092;PartitionState:[topic_30,0] -> (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:7),ReplicationFactor:1),AllReplicas:0),[topic_5,0] -> (LeaderAndIsrInfo:(Leader:-2,ISR:0,LeaderEpoch:0,ControllerEpoch:7),ReplicationFactor:1),AllReplicas:0) from client: /127.0.0.1:55693 (kafka.server.KafkaApis) [2014-11-05 10:31:12,751] TRACE [KafkaApi-0] Handling request: Name:UpdateMetadataRequest;Version:0;Controller:0;ControllerEpoch:7;CorrelationId:8;ClientId:id_0-host_null-port_9092;AliveBrokers:id:0,host:localhost.localdomain,port:9092;PartitionState:[topic_30,0] -> (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:7),ReplicationFactor:1),AllReplicas:0),[topic_5,0] -> (LeaderAndIsrInfo:(Leader:-2,ISR:0,LeaderEpoch:0,ControllerEpoch:7),ReplicationFactor:1),AllReplicas:0) from client: /127.0.0.1:55693 (kafka.server.KafkaApis) [2014-11-05 10:31:12,752] TRACE Processor id 1 selection time = 660576 ns (kafka.network.Processor) [2014-11-05 10:31:12,752] TRACE Processor id 1 selection time = 660576 ns (kafka.network.Processor) [2014-11-05 10:31:12,753] TRACE Socket server received response to send, registering for write: Response(1,Request(1,sun.nio.ch.SelectionKeyImpl@3a6a2cf,null,1415205072751,/127.0.0.1:55693),kafka.network.BoundedByteBufferSend@6d0015b6,SendAction) (kafka.network.Processor) [2014-11-05 10:31:12,753] TRACE Socket server received response to send, registering for write: Response(1,Request(1,sun.nio.ch.SelectionKeyImpl@3a6a2cf,null,1415205072751,/127.0.0.1:55693),kafka.network.BoundedByteBufferSend@6d0015b6,SendAction) (kafka.network.Processor) [2014-11-05 10:31:12,753] TRACE Processor id 1 selection time = 12017 ns (kafka.network.Processor) [2014-11-05 10:31:12,753] TRACE Processor id 1 selection time = 12017 ns (kafka.network.Processor) [2014-11-05 10:31:12,753] TRACE 10 bytes written to /127.0.0.1:55693 using key sun.nio.ch.SelectionKeyImpl@3a6a2cf (kafka.network.Processor) [2014-11-05 10:31:12,753] TRACE 10 bytes written to /127.0.0.1:55693 using key sun.nio.ch.SelectionKeyImpl@3a6a2cf (kafka.network.Processor) [2014-11-05 10:31:12,753] TRACE 6 bytes read. (kafka.network.BoundedByteBufferReceive) [2014-11-05 10:31:12,753] TRACE 6 bytes read. (kafka.network.BoundedByteBufferReceive) [2014-11-05 10:31:12,753] TRACE Finished writing, registering for read on connection /127.0.0.1:55693 (kafka.network.Processor) [2014-11-05 10:31:12,753] TRACE Finished writing, registering for read on connection /127.0.0.1:55693 (kafka.network.Processor)