@Test
public void testRequestTimeoutSetFromConfig() {

	Configuration configuration =  getConfiguration();
	KafkaProducerManager manager = new KafkaProducerManager(configuration);
	KafkaPublishTask.Input input = getInput();
	Properties props = manager.getProducerProperties(input);
	Assert.assertEquals(props.getProperty(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG), "150");
}