Merge pull request #7 from SelimHorri/develop

map object from listener

src/main/java/com/selimhorri/app/config/JsonMapperConfig.java

@@ -0,0 +1,19 @@
+package com.selimhorri.app.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import com.fasterxml.jackson.databind.json.JsonMapper;
+
+@Configuration
+public class JsonMapperConfig {
+
+	@Bean
+	public ObjectMapper getJsonMapper() {
+		return new JsonMapper().configure(SerializationFeature.INDENT_OUTPUT, false);
+	}
+
+
+}

src/main/java/com/selimhorri/app/listener/KafkaListener.java

@@ -2,12 +2,26 @@
 
 import org.springframework.stereotype.Component;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonMappingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.selimhorri.app.model.Message;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
 @Component
+@RequiredArgsConstructor
+@Slf4j
 public class KafkaListener {
 
+	private final ObjectMapper objectMapper;
+
 	@org.springframework.kafka.annotation.KafkaListener(topics = {"NewTopic"}, groupId = "group_id")
-	public void consume(final String msg) {
-		System.out.println(msg);
+	public void consume(final String messageString) throws JsonMappingException, JsonProcessingException {
+		final Message message = this.objectMapper.readValue(messageString.toString(), Message.class);
+		System.err.println(message);
+		log.info("mapped object printed! {}", message);
 	}
 
 

src/main/java/com/selimhorri/app/model/Message.java

@@ -1,12 +1,14 @@
 package com.selimhorri.app.model;
 
+import lombok.AllArgsConstructor;
 import lombok.Data;
-import lombok.RequiredArgsConstructor;
+import lombok.NoArgsConstructor;
 
-@RequiredArgsConstructor
+@NoArgsConstructor
+@AllArgsConstructor
 @Data
 public class Message {
 
-	private final String msg;
+	private String msg;
 
 }