@Test
public void testRequestTimeoutSetFromDefault() {

	KafkaProducerManager manager = new KafkaProducerManager(new SystemPropertiesConfiguration());
	KafkaPublishTask.Input input = getInput();
	Properties props = manager.getProducerProperties(input);
	Assert.assertEquals(props.getProperty(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG), "100");
}