Formatting the files

Author: saurabhoza02

pom.xml

@@ -8,8 +8,8 @@
 		<version>2.1.6.RELEASE</version>
 		<relativePath/> <!-- lookup parent from repository -->
 	</parent>
-	<groupId>io.stockgeeks.springkafka</groupId>
-	<artifactId>spring-kafka-app</artifactId>
+	<groupId>com.onlyfullstack.springkafkaapp</groupId>
+	<artifactId>spring-kafka-docker-tutorial</artifactId>
 	<version>0.0.1-SNAPSHOT</version>
 	<description>Demo project for Spring Boot</description>
 

src/main/java/com/onlyfullstack/springkafkaapp/SpringKafkaAppApplication.java

@@ -10,8 +10,8 @@
 @SpringBootApplication
 public class SpringKafkaAppApplication {
 
-	public static void main(String[] args) {
-		SpringApplication.run(SpringKafkaAppApplication.class, args);
-	}
+    public static void main(String[] args) {
+        SpringApplication.run(SpringKafkaAppApplication.class, args);
+    }
 
 }

src/main/java/com/onlyfullstack/springkafkaapp/config/KafkaConfig.java

@@ -8,9 +8,7 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
-import org.springframework.kafka.annotation.EnableKafka;
 import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
-import org.springframework.kafka.config.KafkaListenerContainerFactory;
 import org.springframework.kafka.core.ConsumerFactory;
 import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
 import org.springframework.kafka.core.DefaultKafkaProducerFactory;
@@ -75,17 +73,15 @@ public ConsumerFactory<String, String> consumerFactory() {
         return new DefaultKafkaConsumerFactory<>(config);
     }
 
-
     @Bean
-    public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
+    public ConcurrentKafkaListenerContainerFactory<String, String> stringKafkaListenerContainerFactory() {
         ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory();
         factory.setConsumerFactory(consumerFactory());
         return factory;
     }
 
-
     @Bean
-    public ConsumerFactory<String, Student> userConsumerFactory() {
+    public ConsumerFactory<String, Student> studentConsumerFactory() {
         Map<String, Object> config = new HashMap<>();
 
         config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
@@ -97,9 +93,9 @@ public ConsumerFactory<String, Student> userConsumerFactory() {
     }
 
     @Bean
-    public ConcurrentKafkaListenerContainerFactory<String, Student> userKafkaListenerFactory() {
+    public ConcurrentKafkaListenerContainerFactory<String, Student> studentKafkaListenerFactory() {
         ConcurrentKafkaListenerContainerFactory<String, Student> factory = new ConcurrentKafkaListenerContainerFactory<>();
-        factory.setConsumerFactory(userConsumerFactory());
+        factory.setConsumerFactory(studentConsumerFactory());
         return factory;
     }
 }

src/main/java/com/onlyfullstack/springkafkaapp/consumers/SimpleConsumer.java

@@ -8,15 +8,15 @@
 @Slf4j
 @Service
 public class SimpleConsumer {
-  @KafkaListener(id = "simple-string-consumer", topics = "simple-string-topic", groupId = "group_id",
-          containerFactory = "kafkaListenerContainerFactory")
-  public void consumeMessage(String message) {
-    log.info("Consumer got Simple String message: {}", message);
-  }
+    @KafkaListener(id = "simple-string-consumer", topics = "simple-string-topic", groupId = "group_id",
+            containerFactory = "stringKafkaListenerContainerFactory")
+    public void consumeMessage(String message) {
+        log.info("Consumer got Simple String message: {}", message);
+    }
 
- @KafkaListener(id = "complex-object-consumer", topics = "complex-object-student-topic",
-         containerFactory = "userKafkaListenerFactory", groupId = "group_json")
-  public void consumeMessage(Student student) {
-    log.info("Consumer got Student message: {}", student);
-  }
+    @KafkaListener(id = "complex-object-consumer", topics = "complex-object-student-topic",
+            containerFactory = "studentKafkaListenerFactory", groupId = "group_json")
+    public void consumeMessage(Student student) {
+        log.info("Consumer got Student message: {}", student);
+    }
 }

src/main/java/com/onlyfullstack/springkafkaapp/controllers/ProducerController.java

@@ -1,9 +1,7 @@
 package com.onlyfullstack.springkafkaapp.controllers;
 
 import com.onlyfullstack.springkafkaapp.models.Student;
-import com.onlyfullstack.springkafkaapp.producers.SimpleProducer;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -19,26 +17,26 @@
 @RequestMapping("/kafka")
 public class ProducerController {
 
-  private final KafkaTemplate<String, String> simpleProducer;
-  private final KafkaTemplate<String, Student> studentKafkaTemplate;
+    private final KafkaTemplate<String, String> simpleProducer;
+    private final KafkaTemplate<String, Student> studentKafkaTemplate;
 
-  public ProducerController(KafkaTemplate<String, String> simpleProducer,
-                            KafkaTemplate<String, Student> studentKafkaTemplate) {
-    this.simpleProducer = simpleProducer;
-    this.studentKafkaTemplate = studentKafkaTemplate;
-  }
+    public ProducerController(KafkaTemplate<String, String> simpleProducer,
+                              KafkaTemplate<String, Student> studentKafkaTemplate) {
+        this.simpleProducer = simpleProducer;
+        this.studentKafkaTemplate = studentKafkaTemplate;
+    }
 
-  @GetMapping(value = "/{message}")
-  public String message(@PathVariable("message") String message) {
-    simpleProducer.send("simple-string-topic", message);
-    return "Message received: " + message;
-  }
+    @GetMapping(value = "/{message}")
+    public String message(@PathVariable("message") String message) {
+        simpleProducer.send("simple-string-topic", message);
+        return "Message received: " + message;
+    }
 
-  @PostMapping
-  @ResponseStatus(HttpStatus.CREATED)
-  public String message(@RequestBody Student student) {
-    log.debug("Received Student in controller : {}", student);
-    studentKafkaTemplate.send("complex-object-student-topic", student);
-    return "Message received: " + student;
-  }
+    @PostMapping
+    @ResponseStatus(HttpStatus.CREATED)
+    public String message(@RequestBody Student student) {
+        log.debug("Received Student in controller : {}", student);
+        studentKafkaTemplate.send("complex-object-student-topic", student);
+        return "Message received: " + student;
+    }
 }

src/test/java/com/onlyfullstack/springkafkaapp/SpringKafkaAppApplicationTests.java

@@ -9,8 +9,8 @@
 @SpringBootTest
 public class SpringKafkaAppApplicationTests {
 
-	@Test
-	public void contextLoads() {
-	}
+    @Test
+    public void contextLoads() {
+    }
 
 }