Merge pull request #49 from ing-bank/feature/Kafka

Feature/kafka

Author: ghoshasish99

.github/workflows/maven.yml

@@ -13,10 +13,10 @@ jobs:
 
     steps:
       - uses: actions/checkout@v4
-      - name: Set up JDK 17
+      - name: Set up JDK 11
         uses: actions/setup-java@v4
         with:
-          java-version: '17'
+          java-version: '11'
           distribution: 'temurin'
           cache: maven
       - name: Build with Maven

Common/src/main/java/com/ing/parent/createParentPOM.java

@@ -153,7 +153,6 @@ private void createFile(String fileName) {
                 // Add default key-value pairs
                 prop.setProperty("setHeadless", "false");
                 prop.setProperty("setSlowMo", "");
-                prop.setProperty("startMaximized", "");
                 prop.setProperty("setDevtools", "");
                 prop.setProperty("setDownloadsPath", "");
                 prop.setProperty("setExecutablePath", "");

Datalib/src/main/java/com/ing/datalib/settings/Capabilities.java

@@ -32,6 +32,10 @@
 import javax.jms.JMSContext;
 import javax.jms.JMSProducer;
 import javax.jms.TextMessage;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.clients.consumer.KafkaConsumer;
+import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerRecord;
 import org.openqa.selenium.WebDriver;
 import org.openqa.selenium.WebElement;
 import org.apache.kafka.common.header.Header;
@@ -132,19 +136,29 @@ public class Command {
 
 
     /**
-     * *** Queue ****
+     * *** Kafka ****
      */
 
     static public Map<String, List<Header>> kafkaHeaders = new HashMap<>();
-    static public Map<String, String> kafkaTopic = new HashMap<>();
+    static public Map<String, String> kafkaProducerTopic = new HashMap<>();
+    static public Map<String, String> kafkaConsumerTopic = new HashMap<>();
+    static public Map<String, String> kafkaConsumerGroupId = new HashMap<>();
     static public Map<String, String> kafkaServers = new HashMap<>();
     static public Map<String, String> kafkaSchemaRegistryURL = new HashMap<>();
     static public Map<String, Integer> kafkaPartition = new HashMap<>();
     static public Map<String, Long> kafkaTimeStamp = new HashMap<>();
     static public Map<String, String> kafkaKey = new HashMap<>();
     static public Map<String, String> kafkaKeySerializer = new HashMap<>();
+    static public Map<String, String> kafkaKeyDeserializer = new HashMap<>();
     static public Map<String, String> kafkaValue = new HashMap<>();
     static public Map<String, String> kafkaValueSerializer = new HashMap<>();
+    static public Map<String, String> kafkaValueDeserializer = new HashMap<>();
+    static public Map<String, ProducerRecord> kafkaProducerRecord = new HashMap<>();
+    static public Map<String, ConsumerRecord> kafkaConsumerRecord = new HashMap<>();
+    static public Map<String, KafkaProducer> kafkaProducer = new HashMap<>();
+    static public Map<String, KafkaConsumer> kafkaConsumer = new HashMap<>();
+    static public Map<String, Integer> kafkaConsumerPollRetries = new HashMap<>();
+    static public Map<String, Long> kafkaConsumerPollDuration = new HashMap<>();
 
 
     /**

Engine/src/main/java/com/ing/engine/commands/browser/Assertions.java

@@ -142,16 +142,6 @@ public void storeVariableInDataSheet() {
         }
     }
 
-    @Action(object = ObjectType.GENERAL, desc = "store  value [<Data>] in Variable [<Condition>]", input = InputType.YES, condition = InputType.YES)
-    public void storeVariable() {
-        if (Condition.startsWith("%") && Condition.endsWith("%")) {
-            addVar(Condition, Data);
-            Report.updateTestLog(Action, "Value" + Data + "' is stored in Variable '" + Condition + "'", Status.DONE);
-        } else {
-            Report.updateTestLog(Action, "Variable format is not correct", Status.DEBUG);
-        }
-    }
-
     public void replaceFunction() {
         String op = "";
         String original = "";