@Test
public void missingRequest_Fail() {

	KafkaPublishTask kPublishTask = new KafkaPublishTask(new SystemPropertiesConfiguration(), new KafkaProducerManager(new SystemPropertiesConfiguration()), objectMapper);
	Task task = new Task();
	kPublishTask.start(Mockito.mock(Workflow.class), task, Mockito.mock(WorkflowExecutor.class));
	Assert.assertEquals(Task.Status.FAILED, task.getStatus());
}