@Test
public void missingBootStrapServers_Fail() {

	Task task = new Task();
	KafkaPublishTask.Input input = new KafkaPublishTask.Input();
	Map<String, Object> value = new HashMap<>();
	input.setValue(value);
	input.setTopic("testTopic");
	task.getInputData().put(KafkaPublishTask.REQUEST_PARAMETER_NAME, input);
	KafkaPublishTask kPublishTask = new KafkaPublishTask(new SystemPropertiesConfiguration(), new KafkaProducerManager(new SystemPropertiesConfiguration()), objectMapper);
	kPublishTask.start(Mockito.mock(Workflow.class), task, Mockito.mock(WorkflowExecutor.class));
	Assert.assertEquals(Task.Status.FAILED, task.getStatus());
}