Initial Commit

src/main/java/com/techprimers/kafka/springbootkafkaconsumerexample/listener/KafkaConsumer.java

@@ -4,16 +4,19 @@ import com.techprimers.kafka.springbootkafkaconsumerexample.model.User;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.stereotype.Service;
 
+import java.util.logging.Logger;
+
 @Service
 public class KafkaConsumer {
 
+    Logger log = Logger.getLogger(String.valueOf(KafkaConsumer.class));
     @KafkaListener(topics="mytest", groupId ="group_id")
     public void consumeMessage(String message){
-        System.out.println("Consumed Message : " + message);
+        log.info("Consumed Message : " + message);
     }
 
     @KafkaListener(topics="mytest_json", groupId ="group_json", containerFactory = "userKafkaListenerFactory")
     public void consumeUser(User userMessage){
-        System.out.println("Consumed User Message : " + userMessage);
+        log.info("Consumed User Message : " + userMessage);
     }
 }