0330 07:36:31.923+0000 {12772} INFO  [m-worker-exec slot-Task:id=10030,env=12772,type=11][c.s.w.t.f.s.PostExecutionStage  ] Loaded {child runId vs completion type}: {10034-SUCCESSFUL}{10035-SUCCESSFUL}{10036-SUCCESSFUL} 
0330 07:10:01.366+0000 {12772} INFO  [m-worker-exec slot-Task:id=10034,env=12772,type=55][edProcessInputBatchKafkaProducer] Started producing records on topic 12772_10034_20170330_IN_0
0330 07:17:42.473+0000 {12772} INFO  [m-worker-exec slot-Task:id=10034,env=12772,type=55][edProcessInputBatchKafkaProducer] Done with producing records on topic 12772_10034_20170330_IN_0 - produced 10000000 records
0330 07:17:42.480+0000 {12772} INFO  [m-worker-exec slot-Task:id=10034,env=12772,type=55][edProcessInputBatchKafkaProducer] Started producing records on topic 12772_10034_20170330_IN_1
0330 07:17:45.033+0000 {12772} INFO  [m-worker-exec slot-Task:id=10034,env=12772,type=55][edProcessInputBatchKafkaProducer] Done with producing records on topic 12772_10034_20170330_IN_1 - produced 100000 records