added consumer for kakfa

app-config-data/src/main/java/com/bharat/microservices/config/KafkaConsumerConfigData.java

@@ -0,0 +1,33 @@
+/**
+ * Created on: 27 Sept 2023 by: BHARAT V logged in as bharatverma from WSL2
+ */
+package com.bharat.microservices.config;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+import lombok.Data;
+
+@Data
+@Configuration
+@ConfigurationProperties(prefix = "kafka-consumer-config")
+public class KafkaConsumerConfigData {
+
+    private String keyDeserializer;
+    private String valueDeserializer;
+    private String consumerGroupId;
+    private String autoOffsetReset;
+    private String specificAvroReaderKey;
+    private String specificAvroReader;
+    private Boolean batchListener;
+    private Boolean autoStartup;
+    private Integer concurrencyLevel;
+    private Integer sessionTimeoutMs;
+    private Integer heartbeatIntervalMs;
+    private Integer maxPollIntervalMs;
+    private Integer maxPollRecords;
+    private Integer maxPartitionFetchBytesDefault;
+    private Integer maxPartitionFetchBytesBoostFactor;
+    private Long pollTimeoutMs;
+
+}

kafka/kafka-consumer/pom.xml

@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.bharat.microservices</groupId>
+        <artifactId>kafka</artifactId>
+        <version>0.0.1-SNAPSHOT</version>
+        <relativePath>../../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>kafka-consumer</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.bharat.microservices</groupId>
+            <artifactId>app-config-data</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.kafka</groupId>
+            <artifactId>spring-kafka</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.avro</groupId>
+            <artifactId>avro</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>

kafka/kafka-consumer/src/main/java/com/bharat/microservices/Main.java

@@ -0,0 +1,12 @@
+package com.bharat.microservices;
+
+
+/*
+ * @author Bharat V. <bindian0509@gmail.com>
+ * @created Wednesday, 27 September 2023
+ */
+public class Main {
+    public static void main(String[] args) {
+        System.out.println("Hello world!");
+    }
+}

kafka/pom.xml

@@ -9,4 +9,4 @@
         <version>0.0.1-SNAPSHOT</version>
     </parent>
     <artifactId>kafka</artifactId>
-</project>
+</project>

pom.xml

@@ -21,6 +21,7 @@
 		<module>kafka/kafka-model</module>
 		<module>kafka/kafka-admin</module>
 		<module>kafka/kafka-producer</module>
+		<module>kafka/kafka-consumer</module>
         <module>config-server</module>
     </modules>
     <packaging>pom</packaging>