KafkaOutputBean.java

public class KafkaOutputBean {

	public void printKafkaBody(String body) {
		try {
			Notification message = new ObjectMapper().readValue(body, Notification.class);
			System.out.println("KafkaBody result >>>>> " + message.toString());
		} catch (JsonParseException e) {
			System.out.println(body + " cannot be marshalled to a Notification.class");
		} catch (JsonMappingException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}

	}
}