[2016-02-03 11:41:05,479] 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)
[2016-02-03 11:41:05,480] DEBUG Processor 0 listening to new connection from /127.0.0.1:54740 (kafka.network.Processor)
[2016-02-03 11:41:05,539] 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)
[2016-02-03 11:41:05,540] DEBUG Processor 1 listening to new connection from /127.0.0.1:54741 (kafka.network.Processor)
[2016-02-03 11:41:05,540] DEBUG Adding index entry 39728 => 1187414 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,540] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,540] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 40296 [0 : 1203778] (kafka.cluster.Partition)
[2016-02-03 11:41:05,541] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,543] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,543] DEBUG [Replica Manager on Broker 0]: Produce to local log in 3 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,559] DEBUG Adding index entry 40296 => 1203778 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,559] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,560] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 40856 [0 : 1220147] (kafka.cluster.Partition)
[2016-02-03 11:41:05,560] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,564] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,564] DEBUG [Replica Manager on Broker 0]: Produce to local log in 5 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,582] DEBUG Adding index entry 40856 => 1220147 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,582] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,582] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 41402 [0 : 1236527] (kafka.cluster.Partition)
[2016-02-03 11:41:05,583] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,589] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,589] DEBUG [Replica Manager on Broker 0]: Produce to local log in 7 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,604] DEBUG Adding index entry 41402 => 1236527 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,605] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,605] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 41948 [0 : 1252907] (kafka.cluster.Partition)
[2016-02-03 11:41:05,605] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,606] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,606] DEBUG [Replica Manager on Broker 0]: Produce to local log in 2 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,614] DEBUG Adding index entry 41948 => 1252907 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,615] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,615] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 42494 [0 : 1269287] (kafka.cluster.Partition)
[2016-02-03 11:41:05,615] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,617] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,617] DEBUG [Replica Manager on Broker 0]: Produce to local log in 3 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,626] DEBUG Adding index entry 42494 => 1269287 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,626] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,626] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 43040 [0 : 1285667] (kafka.cluster.Partition)
[2016-02-03 11:41:05,626] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,629] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,629] DEBUG [Replica Manager on Broker 0]: Produce to local log in 3 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,640] DEBUG Adding index entry 43040 => 1285667 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,640] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,640] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 43586 [0 : 1302047] (kafka.cluster.Partition)
[2016-02-03 11:41:05,640] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,640] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,640] DEBUG [Replica Manager on Broker 0]: Produce to local log in 0 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,645] DEBUG Adding index entry 43586 => 1302047 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,645] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,646] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 44132 [0 : 1318427] (kafka.cluster.Partition)
[2016-02-03 11:41:05,646] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,646] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,646] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,649] DEBUG Adding index entry 44132 => 1318427 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,649] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,649] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 44678 [0 : 1334807] (kafka.cluster.Partition)
[2016-02-03 11:41:05,649] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,649] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,649] DEBUG [Replica Manager on Broker 0]: Produce to local log in 0 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,657] DEBUG Adding index entry 44678 => 1334807 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,657] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,657] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 45224 [0 : 1351187] (kafka.cluster.Partition)
[2016-02-03 11:41:05,657] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,657] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,657] DEBUG [Replica Manager on Broker 0]: Produce to local log in 0 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,660] DEBUG Adding index entry 45224 => 1351187 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,660] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,661] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 45770 [0 : 1367567] (kafka.cluster.Partition)
[2016-02-03 11:41:05,661] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,661] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,661] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,669] DEBUG Adding index entry 45770 => 1367567 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,673] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,676] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 46316 [0 : 1383947] (kafka.cluster.Partition)
[2016-02-03 11:41:05,676] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,676] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,676] DEBUG [Replica Manager on Broker 0]: Produce to local log in 7 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,680] DEBUG Adding index entry 46316 => 1383947 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,680] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,680] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 46862 [0 : 1400327] (kafka.cluster.Partition)
[2016-02-03 11:41:05,680] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,680] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,680] DEBUG [Replica Manager on Broker 0]: Produce to local log in 0 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,685] DEBUG Adding index entry 46862 => 1400327 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,686] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,686] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 47408 [0 : 1416707] (kafka.cluster.Partition)
[2016-02-03 11:41:05,686] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,686] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,686] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,690] DEBUG Adding index entry 47408 => 1416707 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,690] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,690] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 47954 [0 : 1433087] (kafka.cluster.Partition)
[2016-02-03 11:41:05,690] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,690] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,690] DEBUG [Replica Manager on Broker 0]: Produce to local log in 0 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,695] DEBUG Adding index entry 47954 => 1433087 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,695] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,695] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 48500 [0 : 1449467] (kafka.cluster.Partition)
[2016-02-03 11:41:05,695] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,695] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,695] DEBUG [Replica Manager on Broker 0]: Produce to local log in 0 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,703] DEBUG Adding index entry 48500 => 1449467 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,703] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,703] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 49046 [0 : 1465847] (kafka.cluster.Partition)
[2016-02-03 11:41:05,703] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,703] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,703] DEBUG [Replica Manager on Broker 0]: Produce to local log in 0 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,706] DEBUG Adding index entry 49046 => 1465847 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,707] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,707] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 49592 [0 : 1482227] (kafka.cluster.Partition)
[2016-02-03 11:41:05,707] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,707] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,707] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,724] DEBUG Adding index entry 49592 => 1482227 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:41:05,724] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,724] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 49728 [0 : 1486308] (kafka.cluster.Partition)
[2016-02-03 11:41:05,725] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,727] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:41:05,727] DEBUG [Replica Manager on Broker 0]: Produce to local log in 3 ms (kafka.server.ReplicaManager)