implemented subscriber microservice using kafkaConsumer

Author: quantdevv

Diff for: polling-publisher/subscriber-service/src/main/java/com/iluwatar/subscriber/KafkaConsumer.java

@@ -28,7 +28,7 @@
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.stereotype.Service;
 /**
- * Kafak consumer service to consume messages / updates.
+ * Kafka consumer service to consume messages / updates.
  * */
 @Service
 public class KafkaConsumer {

Diff for: polling-publisher/subscriber-service/src/main/resources/application.yml

@@ -0,0 +1,30 @@
+#
+# The MIT License
+# Copyright © 2014-2021 Ilkka Seppälä
+#
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the "Software"), to deal
+# in the Software without restriction, including without limitation the rights
+# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+# copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+#
+# The above copyright notice and this permission notice shall be included in
+# all copies or substantial portions of the Software.
+#
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+# THE SOFTWARE.
+#
+
+server:
+    port: 8082
+
+spring:
+    kafka:
+        consumer:
+            group-id: subscriber-group

Diff for: polling-publisher/subscriber-service/src/test/java/com/iluwatar/subscriber/AppTest.java

@@ -25,10 +25,16 @@
 
 package com.iluwatar.subscriber;
 
-import org.springframework.boot.SpringApplication;
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
 
-public class AppTest {
-  public static void main(String[] args) {
-    SpringApplication.run(App.class, args);
+import static org.junit.jupiter.api.Assertions.*;
+
+@SpringBootTest
+class AppTest {
+
+  @Test
+  void subscriber() {
+    assertDoesNotThrow(() -> App.main(new String[]{}));
   }
-}
+}