@Test
public void noSerializer_StringObject() {

	KafkaPublishTask kPublishTask = new KafkaPublishTask(new SystemPropertiesConfiguration(), new KafkaProducerManager(new SystemPropertiesConfiguration()), objectMapper);
	KafkaPublishTask.Input input = new KafkaPublishTask.Input();
	input.setKey("testStringKey");
	Assert.assertEquals(kPublishTask.getKey(input), "testStringKey");
}