[2016-02-03 11:40:47,742] 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:40:47,743] DEBUG Processor 1 listening to new connection from /127.0.0.1:54738 (kafka.network.Processor)
[2016-02-03 11:40:47,799] 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:40:47,799] DEBUG Processor 2 listening to new connection from /127.0.0.1:54739 (kafka.network.Processor)
[2016-02-03 11:40:47,800] DEBUG Adding index entry 29864 => 892601 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,801] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,801] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 30432 [0 : 908965] (kafka.cluster.Partition)
[2016-02-03 11:40:47,802] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,805] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,806] DEBUG [Replica Manager on Broker 0]: Produce to local log in 6 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,825] DEBUG Adding index entry 30432 => 908965 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,827] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,827] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 30992 [0 : 925334] (kafka.cluster.Partition)
[2016-02-03 11:40:47,827] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,833] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,833] DEBUG [Replica Manager on Broker 0]: Produce to local log in 8 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,845] DEBUG Adding index entry 30992 => 925334 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,845] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,846] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 31538 [0 : 941714] (kafka.cluster.Partition)
[2016-02-03 11:40:47,846] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,851] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,851] DEBUG [Replica Manager on Broker 0]: Produce to local log in 6 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,861] DEBUG Adding index entry 31538 => 941714 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,861] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,861] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 32084 [0 : 958094] (kafka.cluster.Partition)
[2016-02-03 11:40:47,862] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,864] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,864] DEBUG [Replica Manager on Broker 0]: Produce to local log in 3 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,888] DEBUG Adding index entry 32084 => 958094 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,888] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,888] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 32630 [0 : 974474] (kafka.cluster.Partition)
[2016-02-03 11:40:47,889] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,893] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,893] DEBUG [Replica Manager on Broker 0]: Produce to local log in 6 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,901] DEBUG Adding index entry 32630 => 974474 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,902] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,902] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 33176 [0 : 990854] (kafka.cluster.Partition)
[2016-02-03 11:40:47,902] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,904] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,904] DEBUG [Replica Manager on Broker 0]: Produce to local log in 3 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,925] DEBUG Adding index entry 33176 => 990854 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,926] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,926] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 33722 [0 : 1007234] (kafka.cluster.Partition)
[2016-02-03 11:40:47,926] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,926] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,926] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,935] DEBUG Adding index entry 33722 => 1007234 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,935] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,936] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 34268 [0 : 1023614] (kafka.cluster.Partition)
[2016-02-03 11:40:47,936] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,936] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,936] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,958] DEBUG Adding index entry 34268 => 1023614 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,958] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,959] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 34814 [0 : 1039994] (kafka.cluster.Partition)
[2016-02-03 11:40:47,959] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,960] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,960] DEBUG [Replica Manager on Broker 0]: Produce to local log in 2 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,961] DEBUG Adding index entry 34814 => 1039994 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,961] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,961] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 35360 [0 : 1056374] (kafka.cluster.Partition)
[2016-02-03 11:40:47,961] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,962] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,962] DEBUG [Replica Manager on Broker 0]: Produce to local log in 2 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,962] DEBUG Adding index entry 35360 => 1056374 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,962] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,962] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 35906 [0 : 1072754] (kafka.cluster.Partition)
[2016-02-03 11:40:47,962] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,963] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,963] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,963] DEBUG Adding index entry 35906 => 1072754 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,963] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,963] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 36452 [0 : 1089134] (kafka.cluster.Partition)
[2016-02-03 11:40:47,963] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,963] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,963] DEBUG [Replica Manager on Broker 0]: Produce to local log in 0 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,963] DEBUG Adding index entry 36452 => 1089134 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,963] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,963] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 36998 [0 : 1105514] (kafka.cluster.Partition)
[2016-02-03 11:40:47,963] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,963] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,963] DEBUG [Replica Manager on Broker 0]: Produce to local log in 0 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,990] DEBUG Adding index entry 36998 => 1105514 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:47,991] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,991] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 37544 [0 : 1121894] (kafka.cluster.Partition)
[2016-02-03 11:40:47,991] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,993] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:47,993] DEBUG [Replica Manager on Broker 0]: Produce to local log in 3 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,002] DEBUG Adding index entry 37544 => 1121894 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:48,002] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,002] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 38090 [0 : 1138274] (kafka.cluster.Partition)
[2016-02-03 11:40:48,003] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,003] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,003] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,011] DEBUG Adding index entry 38090 => 1138274 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:48,012] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,012] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 38636 [0 : 1154654] (kafka.cluster.Partition)
[2016-02-03 11:40:48,012] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,013] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,013] DEBUG [Replica Manager on Broker 0]: Produce to local log in 2 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,017] DEBUG Adding index entry 38636 => 1154654 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:48,017] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,018] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 39182 [0 : 1171034] (kafka.cluster.Partition)
[2016-02-03 11:40:48,018] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,021] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,021] DEBUG [Replica Manager on Broker 0]: Produce to local log in 4 ms (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,032] DEBUG Adding index entry 39182 => 1171034 to 00000000000000000000.index. (kafka.log.OffsetIndex)
[2016-02-03 11:40:48,032] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,032] DEBUG Partition [test,0] on broker 0: High watermark for partition [test,0] updated to 39728 [0 : 1187414] (kafka.cluster.Partition)
[2016-02-03 11:40:48,033] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 1 fetch requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,034] DEBUG [Replica Manager on Broker 0]: Request key test-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2016-02-03 11:40:48,034] DEBUG [Replica Manager on Broker 0]: Produce to local log in 2 ms (kafka.server.ReplicaManager)