WMS-8022 : Lab 3 : Oracle TEQ / okafka Microservices (#341)

* WMS 8022 - "Simplify Event-driven Apps with TEQ in Oracle Database (with Kafka interoperability)"
Lab 3 - Oracle TEQ broker with okafka  Producer and Consumer Microservices written in Spring Boot

* remove eventmesh from the package name

* remove eventmesh reference from log configuration

Author: pasimoes

workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/eventmesh/kafka/config/consumer/KafkaConsumerConfig.java renamed to workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/kafka/config/consumer/KafkaConsumerConfig.java

@@ -1,6 +1,6 @@
-package com.oracle.developers.eventmesh.kafka.config.consumer;
+package com.oracle.developers.kafka.config.consumer;
 
-import com.oracle.developers.eventmesh.kafka.config.data.KafkaConfigData;
+import com.oracle.developers.kafka.config.data.KafkaConfigData;
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/eventmesh/kafka/config/consumer/KafkaConsumerConfigData.java renamed to workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/kafka/config/consumer/KafkaConsumerConfigData.java

@@ -3,7 +3,7 @@
  ** Copyright (c) 2021 Oracle and/or its affiliates.
  ** Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl/
  */
-package com.oracle.developers.eventmesh.kafka.config.consumer;
+package com.oracle.developers.kafka.config.consumer;
 
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Configuration;

workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/eventmesh/kafka/config/data/KafkaConfigData.java renamed to workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/kafka/config/data/KafkaConfigData.java

@@ -3,7 +3,7 @@
  ** Copyright (c) 2021 Oracle and/or its affiliates.
  ** Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl/
  */
-package com.oracle.developers.eventmesh.kafka.config.data;
+package com.oracle.developers.kafka.config.data;
 
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Configuration;

workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/eventmesh/kafka/config/data/KafkaTopicConfigData.java renamed to workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/kafka/config/data/KafkaTopicConfigData.java

@@ -5,7 +5,7 @@
  ** Copyright (c) 2021 Oracle and/or its affiliates.
  ** Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl/
  */
-package com.oracle.developers.eventmesh.kafka.config.data;
+package com.oracle.developers.kafka.config.data;
 
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Configuration;

workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/eventmesh/kafka/config/data/LabEventData.java renamed to workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/kafka/config/data/LabEventData.java

@@ -1,4 +1,4 @@
-package com.oracle.developers.eventmesh.kafka.config.data;
+package com.oracle.developers.kafka.config.data;
 
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericData;
@@ -11,7 +11,7 @@ public class LabEventData implements Serializable {
     private String message;
 
     public static final String LAB_EVT_SCHEMA =
-            "{\"namespace\": \"com.oracle.developers.eventmesh\","+
+            "{\"namespace\": \"com.oracle.developers\","+
                     "\"type\":\"record\"," +
                     "\"doc\":\"This event records the lab8022\"," +
                     "\"name\":\"LabEvent\"," +

workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/eventmesh/kafka/config/data/LabResponseData.java renamed to workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/kafka/config/data/LabResponseData.java

@@ -1,4 +1,4 @@
-package com.oracle.developers.eventmesh.kafka.config.data;
+package com.oracle.developers.kafka.config.data;
 
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericData;
@@ -12,7 +12,7 @@ public class LabResponseData implements Serializable {
 
     /*
     public static final String LAB_RESPONSE_SCHEMA =
-            "{\"namespace\": \"com.oracle.developers.eventmesh\","+
+            "{\"namespace\": \"com.oracle.developers\","+
                     "\"type\":\"record\"," +
                     "\"doc\":\"Response record from lab8022\"," +
                     "\"name\":\"LabResponse\"," +

workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/eventmesh/kafka/config/producer/KafkaProducerConfig.java renamed to workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/kafka/config/producer/KafkaProducerConfig.java

@@ -1,6 +1,6 @@
-package com.oracle.developers.eventmesh.kafka.config.producer;
+package com.oracle.developers.kafka.config.producer;
 
-import com.oracle.developers.eventmesh.kafka.config.data.KafkaConfigData;
+import com.oracle.developers.kafka.config.data.KafkaConfigData;
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/eventmesh/kafka/config/producer/KafkaProducerConfigData.java renamed to workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-config/src/main/java/com/oracle/developers/kafka/config/producer/KafkaProducerConfigData.java

@@ -3,7 +3,7 @@
  ** Copyright (c) 2021 Oracle and/or its affiliates.
  ** Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl/
  */
-package com.oracle.developers.eventmesh.kafka.config.producer;
+package com.oracle.developers.kafka.config.producer;
 
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Configuration;

workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-consumer/src/main/java/com/oracle/developers/eventmesh/kafka/consumer/KafkaConsumerApplication.java renamed to workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-consumer/src/main/java/com/oracle/developers/kafka/consumer/KafkaConsumerApplication.java

@@ -1,4 +1,4 @@
-package com.oracle.developers.eventmesh.kafka.consumer;
+package com.oracle.developers.kafka.consumer;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -11,10 +11,10 @@
 import org.springframework.util.backoff.FixedBackOff;
 
 @SpringBootApplication
-@ComponentScan(basePackages = "com.oracle.developers.eventmesh.kafka",
+@ComponentScan(basePackages = "com.oracle.developers.kafka",
         excludeFilters =
         @ComponentScan.Filter(type= FilterType.REGEX,
-                pattern="com\\.oracle\\.developers\\.eventmesh\\.kafka\\.config\\.producer\\..*"))
+                pattern="com\\.oracle\\.developers\\.kafka\\.config\\.producer\\..*"))
 public class KafkaConsumerApplication {
 
     public static void main(String[] args) {

workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-consumer/src/main/java/com/oracle/developers/eventmesh/kafka/consumer/service/KafkaConsumerService.java renamed to workshops/microservices-oracleteq-kafka/springboot-kafka/kafka-consumer/src/main/java/com/oracle/developers/kafka/consumer/service/KafkaConsumerService.java

@@ -1,6 +1,6 @@
-package com.oracle.developers.eventmesh.kafka.consumer.service;
+package com.oracle.developers.kafka.consumer.service;
 
-import com.oracle.developers.eventmesh.kafka.config.data.KafkaConfigData;
+import com.oracle.developers.kafka.config.data.KafkaConfigData;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.boot.context.event.ApplicationStartedEvent;