Updated with 1.7.0 release

Author: elans3

rest-db-kafka/pom.xml

@@ -10,7 +10,7 @@
 <maven.compiler.target>8</maven.compiler.target>
 <idaithalam.version>1.7.0</idaithalam.version>
 <testng.ver>7.4.0</testng.ver>
-<avro.version>1.9.2</avro.version>
+<avro.version>1.11.0</avro.version>
 </properties>
 <description>
 This project demonstrate Idaithalam can be integrated with REST API and Kafka message validation.
@@ -139,7 +139,7 @@
 <plugin>
 <groupId>org.apache.avro</groupId>
 <artifactId>avro-maven-plugin</artifactId>
-<version>1.9.1</version>
+<version>${avro.version}</version>
 <executions>
 <execution>
 <phase>generate-sources</phase>

rest-db-kafka/src/test/java/io/virtualan/cucumblan/message/typeimpl/AvroType.java

@@ -11,12 +11,10 @@
 import org.apache.avro.generic.GenericDatumWriter;
 import org.apache.avro.generic.GenericRecord;
 import org.apache.avro.io.*;
-import org.apache.avro.reflect.ReflectDatumWriter;
 import org.codehaus.plexus.util.StringOutputStream;
 
 import java.io.*;
 import java.nio.file.Files;
-import java.nio.file.Path;
 import java.util.Map.Entry;
 
 public class AvroType implements

rest-db-kafka/src/test/java/io/virtualan/test/KafkaTestPlanExecutor.java

@@ -27,13 +27,13 @@ public void execute_orderEvent_protobuff_workflow() {
  }
  }
 
-// @org.testng.annotations.Test
-// public void execute_userEvent_avro_workflow() {
-// try {
-// boolean isSuccess = VirtualanTestPlanExecutor.invoke("workflow/work-flow-avro.yaml");
-// Assert.assertTrue(isSuccess);
-// } catch (Exception e) {
-// e.printStackTrace();
-// }
-// }
+ @org.testng.annotations.Test
+ public void execute_userEvent_avro_workflow() {
+ try {
+ boolean isSuccess = VirtualanTestPlanExecutor.invoke("workflow/work-flow-avro.yaml");
+ Assert.assertTrue(isSuccess);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
 }

rest-db-kafka/src/test/resources/event-xls/CreateUser-Event.xlsx

@@ -18,10 +18,7 @@ apiExecutor:
  session.timeout.ms: 30000
  auto.offset.reset: earliest
  topicProperties:
- OrderCreated: dev01.orderCreated
  CustomerCreated: dev01.customerCreated
- ProductCreated: dev01.productCreated
- UserCreated: dev01.userCreated
  - reportTitle: "2. API with Kafka Event Testing With ProtoBuff"
  env: dev
  outputJsonDir: target/idaithalam
@@ -39,7 +36,4 @@ apiExecutor:
  session.timeout.ms: 30000
  auto.offset.reset: earliest
  topicProperties:
- OrderCreated: dev01.orderCreated
- CustomerCreated: dev01.customerCreated
  ProductCreated: dev01.productCreated
- UserCreated: dev01.userCreated

rest-db-kafka/src/test/resources/workflow/work-flow-proto.yaml

@@ -24,7 +24,3 @@ apiExecutor:
  value.serializer: org.apache.kafka.common.serialization.StringSerializer
  topicProperties:
  OrderCreated: dev01.orderCreated
- CustomerCreated: dev01.customerCreated
- ProductCreated: dev01.productCreated
- StudentCreated: dev01.studentCreated
- UserCreated: dev01.userCreated

rest-db-kafka/src/test/resources/workflow/work-flow.yaml

@@ -1,5 +1,5 @@
 #This is a consumer-proto.properties properties file
-#Tue May 24 08:40:37 CDT 2022
+#Tue May 24 10:19:50 CDT 2022
 key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
 value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer
 bootstrap.servers=microservices.virtualandemo.com\:9092

rest-db-kafka/testscript-generated/customer-proto/consumer-proto.properties

@@ -1,5 +1,5 @@
 #This is a cucumblan.properties properties file
-#Tue May 24 08:40:37 CDT 2022
+#Tue May 24 10:19:50 CDT 2022
 service.api.apiservice=http\://microservices.virtualandemo.com\:9001
 virtualan.data.heading=CustomerCreated-Event - Workflow;
 virtualan.data.type=VIRTUALAN

rest-db-kafka/testscript-generated/customer-proto/cucumblan.properties

@@ -1,5 +1,5 @@
 #This is a topic.properties properties file
-#Tue May 24 08:40:37 CDT 2022
+#Tue May 24 10:19:50 CDT 2022
 ProductCreated=dev01.productCreated
 UserCreated=dev01.userCreated
 CustomerCreated=dev01.customerCreated

rest-db-kafka/testscript-generated/customer-proto/topic.properties

@@ -1,5 +1,5 @@
 #This is a consumer-json.properties properties file
-#Tue May 24 07:57:26 CDT 2022
+#Tue May 24 10:19:56 CDT 2022
 key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
 value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
 bootstrap.servers=microservices.virtualandemo.com\:9092