@Test
public void kafkaPublishUnknownException_Fail() throws ExecutionException, InterruptedException {

	Task task = getTask();
	KafkaProducerManager producerManager = Mockito.mock(KafkaProducerManager.class);
	KafkaPublishTask kPublishTask = new KafkaPublishTask(new SystemPropertiesConfiguration(), producerManager, objectMapper);
	Producer producer = Mockito.mock(Producer.class);
	Mockito.when(producerManager.getProducer(Mockito.any())).thenReturn(producer);
	Mockito.when(producer.send(Mockito.any())).thenThrow(new RuntimeException("Unknown exception"));
	kPublishTask.start(Mockito.mock(Workflow.class), task, Mockito.mock(WorkflowExecutor.class));
	Assert.assertEquals(Task.Status.FAILED, task.getStatus());
	Assert.assertEquals("Failed to invoke kafka task due to: Unknown exception", task.getReasonForIncompletion());
}