@Test
public void testRequestTimeoutSetFromInput() {

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