Upgrade to Debezium 1.2.0.Beta2 apache#1418

integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/AbstractDebeziumTest.java

@@ -43,7 +43,7 @@ public abstract class AbstractDebeziumTest {
     private static String COMPANY_2 = "Even Better Company";
     private static String CITY_1 = "Prague";
     private static String CITY_2 = "Paris";
-    private static int REPEAT_COUNT = 3;
+    public static int REPEAT_COUNT = 3;
 
     /**
      * Each impleentation is responsible for connection creation and its closure.

integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/sqlserver/DebeziumSqlserverTest.java

@@ -89,15 +89,25 @@ protected String getCompanyTableName() {
     @Order(0)
     @EnabledIfSystemProperty(named = PROPERTY_JDBC, matches = ".*")
     public void testReceiveInitCompany() {
-        //receive first record (operation r) for the init company - using larger timeout
-        Response response = receiveResponse("/receiveAsRecord");
+        int i = 0;
 
-        response.then()
-                .statusCode(200);
+        while (i++ < AbstractDebeziumTest.REPEAT_COUNT) {
+            //receive first record (operation r) for the init company - using larger timeout
+            Response response = receiveResponse("/receiveAsRecord");
 
-        Record record = response.getBody().as(Record.class);
-        Assert.assertEquals("r", record.getOperation());
-        Assert.assertEquals("Struct{NAME=init,CITY=init}", record.getValue());
+            response.then()
+                    .statusCode(200);
+
+            Record record = response.getBody().as(Record.class);
+
+            if (record.getOperation() == null) {
+                continue;
+            }
+
+            Assert.assertEquals("r", record.getOperation());
+            Assert.assertEquals("Struct{NAME=init,CITY=init}", record.getValue());
+            break;
+        }
     }
 
     @Test

integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/sqlserver/DebeziumSqlserverTestResource.java

@@ -57,7 +57,15 @@ public Map<String, String> start() {
             return Collections.emptyMap();
         }
 
-        Map<String, String> properties = super.start();
+        Map<String, String> properties;
+        try {
+            properties = super.start();
+        } catch (Exception e) {
+            LOG.warn("If initSqlScript.sql fails with the message 'The error returned was 14258: " +
+                    "'Cannot perform this operation while SQLServerAgent is starting.', " +
+                    "please increase a delay interval in the script.");
+            throw e;
+        }
 
         try {
             historyFile = Files.createTempFile(getClass().getSimpleName() + "-history-file-", "");

integration-tests/debezium/src/test/resources/initSqlserver.sql

@@ -28,18 +28,15 @@ CREATE TABLE Test.COMPANY(
     CITY  varchar(255),
     PRIMARY KEY (NAME)
 );
--- by using system property, sql agent is started, but it could happen that it is not running yet, which will fail
--- during setting of cdc for table. We are waiting for max 20 seconds if service is running
-DECLARE @Counter INT
-SET @Counter=1
-WHILE (SELECT dss.[status] FROM   sys.dm_server_services dss WHERE  dss.[servicename] LIKE N'SQL Server Agent (%') != 4 AND @Counter <= 20
-BEGIN
-	WAITFOR DELAY '00:00:01'
-	SET @Counter  = @Counter  + 1
-END
+-- sql agent is started by providing of the system property, but it could happen that it is still starting during this
+-- execution. In that case, this script fails during setting of cdc for table. In case of failure because of:
+-- 'The error returned was 14258: Cannot perform this operation while SQLServerAgent is starting.'
+-- please increase following delay accordingly
+WAITFOR DELAY '00:00:10'
 
-INSERT INTO Test.COMPANY (name, city) VALUES ('init', 'init');
 EXEC sys.sp_cdc_enable_table @source_schema=N'Test', @source_name=N'COMPANY', @role_name = NULL,@filegroup_name=N'PRIMARY', @supports_net_changes=0;
+INSERT INTO Test.COMPANY (name, city) VALUES ('init', 'init');
+
 
 
 

pom.xml

@@ -47,7 +47,7 @@
         <awssdk1-swf-libs.version>1.11.22</awssdk1-swf-libs.version>
         <awssdk2.version>2.13.33</awssdk2.version>
         <camel.version>3.4.0</camel.version>
-        <debezium.version>1.1.2.Final</debezium.version>
+        <debezium.version>1.2.0.Final</debezium.version>
         <elasticsearch.version>7.6.1</elasticsearch.version>
         <freemarker.version>2.3.30</freemarker.version>
         <github-api.version>1.111</github-api.version>