@Test(expected = RuntimeException.class)
public void testExecutionException() {

	Configuration configuration =  getConfiguration();
	KafkaProducerManager manager = new KafkaProducerManager(configuration);
	KafkaPublishTask.Input input = getInput();
	Producer producer = manager.getProducer(input);
	Assert.assertNotNull(producer);
}