Update integration tests to run for pulsar 3.0 and 4.0

Author: manas-ctds

.github/workflows/github-ci.yml

@@ -35,8 +35,8 @@ jobs:
       - name: Unit tests
         run: mvn -B test -DfailIfNoTests=false -pl streaming-ai,pulsar-transformations,pulsar-ai-tools -Dspotbugs.skip -Dlicense.skip -Dfmt.skip -Dxml-format.skip
 
-  tests-ls:
-    name: Integration tests on Luna Streaming
+  tests-ls-31:
+    name: Integration tests on Luna Streaming 3.1
     runs-on: ubuntu-latest
     needs: build
     steps:
@@ -58,11 +58,11 @@ jobs:
       - name: Build NAR
         run: mvn -B clean package -pl streaming-ai,pulsar-transformations -DskipTests -Dspotbugs.skip -Dlicense.skip -Dfmt.skip -Dxml-format.skip
 
-      - name: Integration tests on Luna Streaming 2.10
-        run: mvn -B test -DfailIfNoTests=false -pl tests -Dtest=DockerTest\$LunaStreaming210Test -Dspotbugs.skip -Dlicense.skip -Dfmt.skip -Dxml-format.skip
+      - name: Integration tests on Luna Streaming 3.1
+        run: mvn -B test -DfailIfNoTests=false -pl tests -Dtest=DockerTest\$LunaStreaming31Test -Dspotbugs.skip -Dlicense.skip -Dfmt.skip -Dxml-format.skip
 
-  tests-pulsar-211:
-    name: Integration tests on Pulsar 2.11
+  tests-ls-40:
+    name: Integration tests on Luna Streaming 4.0
     runs-on: ubuntu-latest
     needs: build
     steps:
@@ -84,10 +84,10 @@ jobs:
       - name: Build NAR
         run: mvn -B clean package -pl streaming-ai,pulsar-transformations -DskipTests -Dspotbugs.skip -Dlicense.skip -Dfmt.skip -Dxml-format.skip
 
-      - name: Integration tests on Pulsar 2.11
-        run: mvn -B test -DfailIfNoTests=false -pl tests -Dtest=DockerTest\$Pulsar211Test -Dspotbugs.skip -Dlicense.skip -Dfmt.skip -Dxml-format.skip
+      - name: Integration tests on Luna Streaming 4.0
+        run: mvn -B test -DfailIfNoTests=false -pl tests -Dtest=DockerTest\$LunaStreaming40Test -Dspotbugs.skip -Dlicense.skip -Dfmt.skip -Dxml-format.skip
 
-  tests-pulsar-3:
+  tests-pulsar-30:
     name: Integration tests on Pulsar 3.0
     runs-on: ubuntu-latest
     needs: build
@@ -112,3 +112,29 @@ jobs:
 
       - name: Integration tests on Pulsar 3.0
         run: mvn -B test -DfailIfNoTests=false -pl tests -Dtest=DockerTest\$Pulsar30Test -Dspotbugs.skip -Dlicense.skip -Dfmt.skip -Dxml-format.skip
+
+  tests-pulsar-40:
+    name: Integration tests on Pulsar 4.0
+    runs-on: ubuntu-latest
+    needs: build
+    steps:
+      - uses: actions/checkout@v2
+      - name: Set up JDK 11
+        uses: actions/setup-java@v2
+        with:
+          java-version: '11'
+          distribution: 'adopt'
+
+      - name: Cache local Maven repository
+        uses: actions/cache@v3
+        with:
+          path: ~/.m2/repository
+          key: ${{ runner.os }}-maven-${{ hashFiles('**/pom.xml') }}
+          restore-keys: |
+            ${{ runner.os }}-maven-
+
+      - name: Build NAR
+        run: mvn -B clean package -pl streaming-ai,pulsar-transformations -DskipTests -Dspotbugs.skip -Dlicense.skip -Dfmt.skip -Dxml-format.skip
+
+      - name: Integration tests on Pulsar 4.0
+        run: mvn -B test -DfailIfNoTests=false -pl tests -Dtest=DockerTest\$Pulsar40Test -Dspotbugs.skip -Dlicense.skip -Dfmt.skip -Dxml-format.skip

tests/src/test/java/com/datastax/oss/pulsar/functions/transforms/tests/DockerTest.java

@@ -17,19 +17,20 @@
 
 public class DockerTest {
 
-  private static final String IMAGE_LUNASTREAMING210 = "datastax/lunastreaming:2.10_4.7";
-  private static final String IMAGE_PULSAR211 = "apachepulsar/pulsar:2.11.1";
-  private static final String IMAGE_PULSAR30 = "apachepulsar/pulsar:3.0.0";
+  private static final String IMAGE_LUNASTREAMING31 = "datastax/lunastreaming:3.1.4_26";
+  private static final String IMAGE_LUNASTREAMING40 = "datastax/lunastreaming:4.0.7_7";
+  private static final String IMAGE_PULSAR30 = "apachepulsar/pulsar:3.0.17";
+  private static final String IMAGE_PULSAR40 = "apachepulsar/pulsar:4.0.10";
 
-  public static class LunaStreaming210Test extends AbstractDockerTest {
-    LunaStreaming210Test() {
-      super(IMAGE_LUNASTREAMING210);
+  public static class LunaStreaming31Test extends AbstractDockerTest {
+    LunaStreaming31Test() {
+      super(IMAGE_LUNASTREAMING31);
     }
   }
 
-  public static class Pulsar211Test extends AbstractDockerTest {
-    Pulsar211Test() {
-      super(IMAGE_PULSAR211);
+  public static class LunaStreaming40Test extends AbstractDockerTest {
+    LunaStreaming40Test() {
+      super(IMAGE_LUNASTREAMING40);
     }
   }
 
@@ -38,4 +39,10 @@ public static class Pulsar30Test extends AbstractDockerTest {
       super(IMAGE_PULSAR30);
     }
   }
+
+  public static class Pulsar40Test extends AbstractDockerTest {
+    Pulsar40Test() {
+      super(IMAGE_PULSAR40);
+    }
+  }
 }