@Test
public void integerSerializer_integerObject() {

	KafkaPublishTask kPublishTask = new KafkaPublishTask(new SystemPropertiesConfiguration(), new KafkaProducerManager(new SystemPropertiesConfiguration()), objectMapper);
	KafkaPublishTask.Input input = new KafkaPublishTask.Input();
	input.setKeySerializer(IntegerSerializer.class.getCanonicalName());
	input.setKey(String.valueOf(Integer.MAX_VALUE));
	Assert.assertEquals(kPublishTask.getKey(input), new Integer(Integer.MAX_VALUE));
}