[2014-07-28 11:31:18,024]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9488 to 9488
[2014-07-28 11:31:18,024]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["9"], "idField": "id-5-59"}
[2014-07-28 11:31:18,032]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9489 to 9489
[2014-07-28 11:31:18,032]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["7"], "idField": "id-3-59"}
[2014-07-28 11:31:18,040]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9490 to 9490
[2014-07-28 11:31:18,040]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["19"], "idField": "id-7-59"}
[2014-07-28 11:31:18,048]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9491 to 9491
[2014-07-28 11:31:18,048]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["7"], "idField": "id-1-59"}
[2014-07-28 11:31:18,057]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9492 to 9492
[2014-07-28 11:31:18,057]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["11"], "idField": "id-6-59"}
[2014-07-28 11:31:18,065]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9493 to 9493
[2014-07-28 11:31:18,065]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["9"], "idField": "id-4-58"}
[2014-07-28 11:31:18,074]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9494 to 9494
[2014-07-28 11:31:18,074]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["6"], "idField": "id-0-59"}
[2014-07-28 11:31:18,082]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9495 to 9495
[2014-07-28 11:31:18,082]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["19"], "idField": "id-2-58"}
[2014-07-28 11:31:18,090]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9496 to 9496
[2014-07-28 11:31:18,090]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["7"], "idField": "id-0-59"}
[2014-07-28 11:31:18,112]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9497 to 9497
[2014-07-28 11:31:18,113]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["8"], "idField": "id-3-59"}
[2014-07-28 11:31:18,120]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9498 to 9498
[2014-07-28 11:31:18,120]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["0"], "idField": "id-7-60"}
[2014-07-28 11:31:18,128]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9499 to 9499
[2014-07-28 11:31:18,128]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["8"], "idField": "id-1-59"}
[2014-07-28 11:31:18,135]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [kafka.consumer.PartitionTopicInfo]  reset consume offset of EventServiceUpsertTopic:11: fetched offset = 9500: consumed offset = 9500 to 9500
[2014-07-28 11:31:18,136]  [DEBUG]  [pipeline-thread-0 (indexing-pipeline)]  [c.a.a.p.e.EventService]  Adding to bulk upsert operation: {"field1": ["12"], "idField": "id-6-59"}