[2014-07-28 11:29:43,126]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9224 => 2477287 to 00000000000000000000.index.
[2014-07-28 11:29:43,175]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9240 => 2481563 to 00000000000000000000.index.
[2014-07-28 11:29:43,270]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9259 => 2486661 to 00000000000000000000.index.
[2014-07-28 11:29:43,331]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9279 => 2491998 to 00000000000000000000.index.
[2014-07-28 11:29:43,392]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9295 => 2496267 to 00000000000000000000.index.
[2014-07-28 11:29:43,456]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9311 => 2500521 to 00000000000000000000.index.
[2014-07-28 11:29:43,484]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9327 => 2504788 to 00000000000000000000.index.
[2014-07-28 11:29:43,546]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9344 => 2509329 to 00000000000000000000.index.
[2014-07-28 11:29:43,595]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9365 => 2514969 to 00000000000000000000.index.
[2014-07-28 11:29:43,642]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9381 => 2519273 to 00000000000000000000.index.
[2014-07-28 11:29:43,716]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9397 => 2523583 to 00000000000000000000.index.
[2014-07-28 11:29:43,733]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9414 => 2528158 to 00000000000000000000.index.
[2014-07-28 11:29:43,783]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9430 => 2532466 to 00000000000000000000.index.
[2014-07-28 11:29:43,853]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9452 => 2538356 to 00000000000000000000.index.
[2014-07-28 11:29:43,917]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9468 => 2542638 to 00000000000000000000.index.
[2014-07-28 11:29:43,967]  [DEBUG]  [ReplicaFetcherThread-0-0]  [kafka.log.OffsetIndex]  Adding index entry 9486 => 2547460 to 00000000000000000000.index.
[2014-07-28 11:29:44,002]  [INFO ]  [kafka-request-handler-7]  [kafka.server.ReplicaFetcherManager]  [ReplicaFetcherManager on broker 2] Removed fetcher for partitions [EventServiceUpsertTopic,11],[EventServiceUpsertTopic,17],[EventServiceUpsertTopic,14],[EventServiceUpsertTopic,8],[EventServiceUpsertTopic,2],[EventServiceUpsertTopic,5]
[2014-07-28 11:29:44,014]  [DEBUG]  [kafka-request-handler-1]  [kafka.server.KafkaApis]  [KafkaApi-2] Maybe update partition HW due to fetch request: Name: FetchRequest; Version: 0; CorrelationId: 0; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 1; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,11] -> PartitionFetchInfo(9497,1048576),[EventServiceUpsertTopic,17] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,5] -> PartitionFetchInfo(0,1048576) 
[2014-07-28 11:29:44,014]  [DEBUG]  [kafka-request-handler-0]  [kafka.server.KafkaApis]  [KafkaApi-2] Maybe update partition HW due to fetch request: Name: FetchRequest; Version: 0; CorrelationId: 0; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 0; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,11] -> PartitionFetchInfo(9499,1048576),[EventServiceUpsertTopic,17] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,5] -> PartitionFetchInfo(0,1048576) 
[2014-07-28 11:29:44,015]  [DEBUG]  [kafka-request-handler-1]  [kafka.cluster.Partition]  Partition [EventServiceUpsertTopic,11] on broker 2: Recording follower 1 position 9497 for partition [EventServiceUpsertTopic,11].
[2014-07-28 11:29:44,016]  [DEBUG]  [kafka-request-handler-0]  [kafka.cluster.Partition]  Partition [EventServiceUpsertTopic,11] on broker 2: Recording follower 0 position 9499 for partition [EventServiceUpsertTopic,11].
[2014-07-28 11:29:44,016]  [DEBUG]  [kafka-request-handler-7]  [kafka.cluster.Partition]  Partition [EventServiceUpsertTopic,11] on broker 2: Old hw for partition [EventServiceUpsertTopic,11] is 9499. New hw is -1. All leo's are -1,9500
[2014-07-28 11:29:44,025]  [DEBUG]  [kafka-request-handler-0]  [kafka.server.KafkaApis]  [KafkaApi-2] Leader 2 for partition [EventServiceUpsertTopic,11] received fetch request from follower 0
[2014-07-28 11:29:44,025]  [DEBUG]  [kafka-request-handler-1]  [kafka.server.KafkaApis]  [KafkaApi-2] Leader 2 for partition [EventServiceUpsertTopic,11] received fetch request from follower 1
[2014-07-28 11:29:44,045]  [DEBUG]  [kafka-processor-54383-1]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 0; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 1; MaxWait: 500 ms; MinBytes: 1 bytes from client /127.0.0.1:54471;totalTime:32,requestQueueTime:0,localTime:28,remoteTime:0,responseQueueTime:1,sendTime:3
[2014-07-28 11:29:44,045]  [DEBUG]  [kafka-processor-54383-0]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 0; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 0; MaxWait: 500 ms; MinBytes: 1 bytes from client /127.0.0.1:54470;totalTime:36,requestQueueTime:2,localTime:29,remoteTime:0,responseQueueTime:1,sendTime:4
[2014-07-28 11:29:44,047]  [DEBUG]  [kafka-request-handler-3]  [kafka.server.KafkaApis]  [KafkaApi-2] Maybe update partition HW due to fetch request: Name: FetchRequest; Version: 0; CorrelationId: 1; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 1; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,11] -> PartitionFetchInfo(9500,1048576),[EventServiceUpsertTopic,17] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,5] -> PartitionFetchInfo(0,1048576) 
[2014-07-28 11:29:44,047]  [DEBUG]  [kafka-request-handler-4]  [kafka.server.KafkaApis]  [KafkaApi-2] Maybe update partition HW due to fetch request: Name: FetchRequest; Version: 0; CorrelationId: 1; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 0; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,11] -> PartitionFetchInfo(9500,1048576),[EventServiceUpsertTopic,17] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,5] -> PartitionFetchInfo(0,1048576) 
[2014-07-28 11:29:44,047]  [DEBUG]  [kafka-request-handler-3]  [kafka.cluster.Partition]  Partition [EventServiceUpsertTopic,11] on broker 2: Recording follower 1 position 9500 for partition [EventServiceUpsertTopic,11].
[2014-07-28 11:29:44,047]  [DEBUG]  [kafka-request-handler-3]  [kafka.cluster.Partition]  Partition [EventServiceUpsertTopic,11] on broker 2: Old hw for partition [EventServiceUpsertTopic,11] is 9499. New hw is -1. All leo's are -1,9500
[2014-07-28 11:29:44,047]  [DEBUG]  [kafka-request-handler-4]  [kafka.cluster.Partition]  Partition [EventServiceUpsertTopic,11] on broker 2: Recording follower 0 position 9500 for partition [EventServiceUpsertTopic,11].
[2014-07-28 11:29:44,049]  [DEBUG]  [kafka-request-handler-4]  [kafka.cluster.Partition]  Partition [EventServiceUpsertTopic,11] on broker 2: Highwatermark for partition [EventServiceUpsertTopic,11] updated to 9500
[2014-07-28 11:29:44,050]  [DEBUG]  [kafka-request-handler-3]  [kafka.server.KafkaApis]  [KafkaApi-2] Leader 2 for partition [EventServiceUpsertTopic,11] received fetch request from follower 1
[2014-07-28 11:29:44,051]  [DEBUG]  [kafka-request-handler-4]  [kafka.server.KafkaApis]  [KafkaApi-2] Leader 2 for partition [EventServiceUpsertTopic,11] received fetch request from follower 0
[2014-07-28 11:29:44,052]  [DEBUG]  [kafka-request-handler-3]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 1 from client ReplicaFetcherThread-0-2 into purgatory
[2014-07-28 11:29:44,052]  [DEBUG]  [kafka-request-handler-4]  [kafka.server.KafkaApis]  [KafkaApi-2] Leader 2 for partition [EventServiceUpsertTopic,5] received fetch request from follower 0
[2014-07-28 11:29:44,053]  [DEBUG]  [kafka-request-handler-4]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 1 from client ReplicaFetcherThread-0-2 into purgatory
[2014-07-28 11:29:44,108]  [DEBUG]  [kafka-acceptor]  [kafka.network.Acceptor]  Accepted connection from /127.0.0.1 on /127.0.0.1:54383. sendBufferSize [actual|requested]: [102400|102400] recvBufferSize [actual|requested]: [244980|102400]
[2014-07-28 11:29:44,109]  [DEBUG]  [kafka-processor-54383-2]  [kafka.network.Processor]  Processor 2 listening to new connection from /127.0.0.1:54473
[2014-07-28 11:29:44,110]  [DEBUG]  [kafka-request-handler-5]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 0 from client EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2 into purgatory
[2014-07-28 11:29:44,212]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 0; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:44,213]  [DEBUG]  [kafka-processor-54383-2]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 0; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes from client /127.0.0.1:54473;totalTime:104,requestQueueTime:0,localTime:1,remoteTime:102,responseQueueTime:0,sendTime:1
[2014-07-28 11:29:44,215]  [DEBUG]  [kafka-request-handler-6]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 1 from client EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2 into purgatory
[2014-07-28 11:29:44,320]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 1; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:44,322]  [DEBUG]  [kafka-processor-54383-2]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 1; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes from client /127.0.0.1:54473;totalTime:106,requestQueueTime:0,localTime:1,remoteTime:105,responseQueueTime:0,sendTime:0
[2014-07-28 11:29:44,323]  [DEBUG]  [kafka-request-handler-7]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 2 from client EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2 into purgatory
[2014-07-28 11:29:44,424]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 2; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:44,425]  [DEBUG]  [kafka-processor-54383-2]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 2; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes from client /127.0.0.1:54473;totalTime:102,requestQueueTime:0,localTime:0,remoteTime:101,responseQueueTime:0,sendTime:1
[2014-07-28 11:29:44,428]  [DEBUG]  [kafka-request-handler-2]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 3 from client EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2 into purgatory
[2014-07-28 11:29:44,529]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 3; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:44,530]  [DEBUG]  [kafka-processor-54383-2]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 3; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes from client /127.0.0.1:54473;totalTime:103,requestQueueTime:0,localTime:1,remoteTime:101,responseQueueTime:1,sendTime:0
[2014-07-28 11:29:44,533]  [DEBUG]  [kafka-request-handler-1]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 4 from client EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2 into purgatory
[2014-07-28 11:29:44,559]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 1; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 0; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,11] -> PartitionFetchInfo(9500,1048576),[EventServiceUpsertTopic,17] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,5] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:44,559]  [DEBUG]  [request-expiration-task]  [kafka.server.KafkaApis]  [KafkaApi-2] Leader 2 for partition [EventServiceUpsertTopic,11] received fetch request from follower 0
[2014-07-28 11:29:44,562]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 1; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 1; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,11] -> PartitionFetchInfo(9500,1048576),[EventServiceUpsertTopic,17] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,5] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:44,562]  [DEBUG]  [request-expiration-task]  [kafka.server.KafkaApis]  [KafkaApi-2] Leader 2 for partition [EventServiceUpsertTopic,11] received fetch request from follower 1
[2014-07-28 11:29:44,563]  [DEBUG]  [kafka-processor-54383-0]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 1; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 0; MaxWait: 500 ms; MinBytes: 1 bytes from client /127.0.0.1:54470;totalTime:516,requestQueueTime:0,localTime:13,remoteTime:502,responseQueueTime:1,sendTime:0
[2014-07-28 11:29:44,564]  [DEBUG]  [kafka-request-handler-0]  [kafka.server.KafkaApis]  [KafkaApi-2] Maybe update partition HW due to fetch request: Name: FetchRequest; Version: 0; CorrelationId: 2; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 0; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,11] -> PartitionFetchInfo(9500,1048576),[EventServiceUpsertTopic,17] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,5] -> PartitionFetchInfo(0,1048576) 
[2014-07-28 11:29:44,564]  [DEBUG]  [kafka-request-handler-0]  [kafka.cluster.Partition]  Partition [EventServiceUpsertTopic,11] on broker 2: Recording follower 0 position 9500 for partition [EventServiceUpsertTopic,11].
[2014-07-28 11:29:44,565]  [DEBUG]  [kafka-request-handler-0]  [kafka.cluster.Partition]  Partition [EventServiceUpsertTopic,11] on broker 2: Old hw for partition [EventServiceUpsertTopic,11] is 9500. New hw is 9500. All leo's are 9500
[2014-07-28 11:29:44,567]  [DEBUG]  [kafka-request-handler-4]  [kafka.server.KafkaApis]  [KafkaApi-2] Maybe update partition HW due to fetch request: Name: FetchRequest; Version: 0; CorrelationId: 2; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 1; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,11] -> PartitionFetchInfo(9500,1048576),[EventServiceUpsertTopic,17] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,5] -> PartitionFetchInfo(0,1048576) 
[2014-07-28 11:29:44,567]  [DEBUG]  [kafka-request-handler-0]  [kafka.server.KafkaApis]  [KafkaApi-2] Replica 0 fetch unblocked 0 producer requests.
[2014-07-28 11:29:44,567]  [DEBUG]  [kafka-request-handler-4]  [kafka.cluster.Partition]  Partition [EventServiceUpsertTopic,11] on broker 2: Recording follower 1 position 9500 for partition [EventServiceUpsertTopic,11].
[2014-07-28 11:29:44,567]  [DEBUG]  [kafka-request-handler-4]  [kafka.cluster.Partition]  Partition [EventServiceUpsertTopic,11] on broker 2: Old hw for partition [EventServiceUpsertTopic,11] is 9500. New hw is 9500. All leo's are 9500
[2014-07-28 11:29:44,568]  [DEBUG]  [kafka-request-handler-0]  [kafka.server.KafkaApis]  [KafkaApi-2] Leader 2 for partition [EventServiceUpsertTopic,11] received fetch request from follower 0
[2014-07-28 11:29:44,569]  [DEBUG]  [kafka-request-handler-4]  [kafka.server.KafkaApis]  [KafkaApi-2] Leader 2 for partition [EventServiceUpsertTopic,11] received fetch request from follower 1
[2014-07-28 11:29:44,570]  [DEBUG]  [kafka-request-handler-4]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 2 from client ReplicaFetcherThread-0-2 into purgatory
[2014-07-28 11:29:44,634]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 4; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:44,636]  [DEBUG]  [kafka-processor-54383-2]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 4; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes from client /127.0.0.1:54473;totalTime:103,requestQueueTime:0,localTime:1,remoteTime:102,responseQueueTime:0,sendTime:0
[2014-07-28 11:29:44,637]  [DEBUG]  [kafka-request-handler-3]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 5 from client EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2 into purgatory
[2014-07-28 11:29:44,672]  [DEBUG]  [ReplicaFetcherThread-0-1]  [kafka.log.OffsetIndex]  Adding index entry 16 => 4255 to 00000000000000000000.index.
[2014-07-28 11:29:44,739]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 5; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:44,740]  [DEBUG]  [kafka-processor-54383-2]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 5; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes from client /127.0.0.1:54473;totalTime:103,requestQueueTime:0,localTime:0,remoteTime:102,responseQueueTime:1,sendTime:0
[2014-07-28 11:29:44,743]  [DEBUG]  [kafka-request-handler-5]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 6 from client EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2 into purgatory
[2014-07-28 11:29:44,768]  [DEBUG]  [main-SendThread(localhost:54132)]  [org.apache.zookeeper.ClientCnxn]  Got ping response for sessionid: 0x477e3ae5510002 after 0ms
[2014-07-28 11:29:44,844]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 6; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:44,846]  [DEBUG]  [kafka-processor-54383-2]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 6; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes from client /127.0.0.1:54473;totalTime:103,requestQueueTime:0,localTime:1,remoteTime:102,responseQueueTime:0,sendTime:0
[2014-07-28 11:29:44,847]  [DEBUG]  [kafka-request-handler-6]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 7 from client EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2 into purgatory
[2014-07-28 11:29:44,873]  [DEBUG]  [ReplicaFetcherThread-0-1]  [kafka.log.OffsetIndex]  Adding index entry 32 => 8531 to 00000000000000000000.index.
[2014-07-28 11:29:44,949]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 7; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:44,951]  [DEBUG]  [kafka-processor-54383-2]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 7; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes from client /127.0.0.1:54473;totalTime:103,requestQueueTime:0,localTime:1,remoteTime:102,responseQueueTime:0,sendTime:0
[2014-07-28 11:29:44,952]  [DEBUG]  [kafka-request-handler-7]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 8 from client EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2 into purgatory
[2014-07-28 11:29:45,051]  [DEBUG]  [ReplicaFetcherThread-0-1]  [kafka.log.OffsetIndex]  Adding index entry 48 => 12803 to 00000000000000000000.index.
[2014-07-28 11:29:45,054]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 8; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:45,056]  [DEBUG]  [kafka-processor-54383-2]  [kafka.request.logger]  Completed request:Name: FetchRequest; Version: 0; CorrelationId: 8; ClientId: EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2; ReplicaId: -1; MaxWait: 100 ms; MinBytes: 1 bytes from client /127.0.0.1:54473;totalTime:103,requestQueueTime:0,localTime:0,remoteTime:103,responseQueueTime:0,sendTime:0
[2014-07-28 11:29:45,057]  [DEBUG]  [kafka-request-handler-2]  [kafka.server.KafkaApis]  [KafkaApi-2] Putting fetch request with correlation id 9 from client EventServiceGroupId-ConsumerFetcherThread-EventServiceGroupId_0-kafka-0-0-2 into purgatory
[2014-07-28 11:29:45,071]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 2; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 0; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,11] -> PartitionFetchInfo(9500,1048576),[EventServiceUpsertTopic,17] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,5] -> PartitionFetchInfo(0,1048576).
[2014-07-28 11:29:45,071]  [DEBUG]  [request-expiration-task]  [kafka.server.KafkaApis]  [KafkaApi-2] Leader 2 for partition [EventServiceUpsertTopic,11] received fetch request from follower 0
[2014-07-28 11:29:45,074]  [DEBUG]  [request-expiration-task]  [k.s.KafkaApis$FetchRequestPurgatory]  [FetchRequestPurgatory-2] Expiring fetch request Name: FetchRequest; Version: 0; CorrelationId: 2; ClientId: ReplicaFetcherThread-0-2; ReplicaId: 1; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [EventServiceUpsertTopic,11] -> PartitionFetchInfo(9500,1048576),[EventServiceUpsertTopic,17] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,14] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,8] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,2] -> PartitionFetchInfo(0,1048576),[EventServiceUpsertTopic,5] -> PartitionFetchInfo(0,1048576).