[2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [c.a.a.p.k.producer.KafkaEventService] Sending upsert request [{"field1": ["10"], "idField": "id-5-59"}] [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [k.producer.async.DefaultEventHandler] Handling 1 events [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Getting broker partition info for topic EventServiceUpsertTopic [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,0] has leader 1 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,1] has leader 0 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,2] has leader 1 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,3] has leader 0 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,4] has leader 1 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,5] has leader 0 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,6] has leader 1 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,7] has leader 0 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,8] has leader 1 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,9] has leader 0 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,10] has leader 1 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,11] has leader 0 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,12] has leader 1 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,13] has leader 0 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,14] has leader 1 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,15] has leader 0 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,16] has leader 1 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,17] has leader 0 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,18] has leader 1 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [kafka.producer.BrokerPartitionInfo] Partition [EventServiceUpsertTopic,19] has leader 0 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [k.producer.async.DefaultEventHandler] Broker partitions registered for topic: EventServiceUpsertTopic are 0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19 [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [k.producer.async.DefaultEventHandler] Sending 1 messages with compression codec 1 to [EventServiceUpsertTopic,11] [2014-07-28 11:29:43,995] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [k.producer.async.DefaultEventHandler] Producer sending messages with correlation id 19029 for topics [EventServiceUpsertTopic,11] to broker 0 on localhost:54156 [2014-07-28 11:29:43,997] [DEBUG] [dw-99 - PATCH /v1/events/type_for_test_bringupNewBroker_shouldRebalance_shouldNotLoseData/event?_idPath=idField&_mergeFields=field1] [k.producer.async.DefaultEventHandler] Producer sent messages with correlation id 19029 for topics [EventServiceUpsertTopic,11] to broker 0 on localhost:54156