Added docker-compose.yaml for starting local kafka, added KafkaTopicConfig and...

Added docker-compose.yaml for starting local kafka, added KafkaTopicConfig and renamed ObjectMapperConfiguration for consistency.

docker-compose.yaml

+version: '3.8'
+services:
+
+  zookeeper:
+    image: strimzi/kafka:0.20.0-kafka-2.6.0
+    command: [
+        "sh", "-c", "bin/zookeeper-server-start.sh config/zookeeper.properties"
+    ]
+    ports:
+      - "2181:2181"
+    environment:
+      LOG_DIR: /tmp/logs
+
+  kafka:
+    image: strimzi/kafka:0.20.0-kafka-2.6.0
+    command: [
+        "sh", "-c", "bin/kafka-server-start.sh config/server.properties --override listeners=$${KAFKA_LISTENERS} --override advertised.listeners=$${KAFKA_ADVERTISED_LISTENERS} --override zookeeper.connect=$${KAFKA_ZOOKEEPER_CONNECT}"
+    ]
+    depends_on:
+      - zookeeper
+    ports:
+      - "9092:9092"
+    environment:
+      LOG_DIR: "/tmp/logs"
+      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092
+      KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092
+      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
\ No newline at end of file

src/main/java/org/opengroup/osdu/streaming/util/KafkaTopicConfiguration.java

+package org.opengroup.osdu.streaming.util;
+
+import org.apache.kafka.clients.admin.AdminClientConfig;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.kafka.core.KafkaAdmin;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Configuration
+public class KafkaTopicConfiguration {
+
+    @Value(value = "${kafka.bootstrapAddress:localhost:9092}")
+    private String bootstrapAddress;
+
+    @Bean
+    public KafkaAdmin kafkaAdmin() {
+        Map<String, Object> configs = new HashMap<>();
+        configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
+        return new KafkaAdmin(configs);
+    }
+
+}

src/main/java/org/opengroup/osdu/streaming/util/ObjectMapperProvider.java → src/main/java/org/opengroup/osdu/streaming/util/ObjectMapperConfiguration.java

@@ -3,9 +3,11 @@ package org.opengroup.osdu.streaming.util;
 import com.fasterxml.jackson.databind.DeserializationFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Primary;
 
-public class ObjectMapperProvider {
+@Configuration
+public class ObjectMapperConfiguration {
 
     @Bean
     @Primary