@Test
public void testMaxBlockMsFromConfig() {

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