Upgrading Debezium

Author: ilgrosso

common/idrepo/rest-api/src/main/java/org/apache/syncope/common/rest/api/service/ExecutableService.java

@@ -134,5 +134,5 @@ public interface ExecutableService extends JAXRSService {
             @ApiResponse(responseCode = "204", description = "Operation was successful"))
     @POST
     @Path("jobs/{key}")
-    void actionJob(@NotNull @PathParam("key") String key, @QueryParam("action") JobAction action);
+    void actionJob(@NotNull @PathParam("key") String key, @NotNull @QueryParam("action") JobAction action);
 }

core/persistence-jpa/src/test/resources/domains/MasterContent.xml

@@ -560,7 +560,7 @@ under the License.
                 bundleName="net.tirasa.connid.bundles.kafka"
                 connectorName="net.tirasa.connid.bundles.kafka.KafkaConnector"
                 version="${connid.kafka.version}"
-                jsonConf='[{"schema":{"name":"bootstrapServers","displayName":"Bootstrap servers","helpMessage":"A list of host/port pairs used to establish the initial connection to the Kafka cluster","type":"java.lang.String","required":true,"order":1,"confidential":false,"defaultValues":[]},"values":["localhost:19092"],"overridable":false},{"schema":{"name":"clientId","displayName":"Client id","helpMessage":"Client id for subscription","type":"java.lang.String","required":true,"order":2,"confidential":false,"defaultValues":[]},"values":["syncope"],"overridable":false},{"schema":{"name":"consumerGroupId","displayName":"Consumer Group id","helpMessage":"A unique string that identifies the consumer group this consumer belongs to.","type":"java.lang.String","required":true,"order":3,"confidential":false,"defaultValues":[]},"values":["syncope"],"overridable":false},{"schema":{"name":"autoOffsetReset","displayName":"Auto offset reset","helpMessage":"What to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server (e.g. because that data has been deleted); defaults to earliest in order to make sure the producer sent all messages before the consumer starts.","type":"java.lang.String","required":true,"order":4,"confidential":false,"defaultValues":["earliest"]},"values":["earliest"],"overridable":false},{"schema":{"name":"valueSerializerClassName","displayName":"Value serializer class","helpMessage":"Serializer class for value that implements the org.apache.kafka.common.serialization.Serializer interface. Defaults to net.tirasa.connid.bundles.kafka.serialization.SyncDeltaSerializer","type":"java.lang.String","required":true,"order":5,"confidential":false,"defaultValues":["net.tirasa.connid.bundles.kafka.serialization.SyncDeltaSerializer"]},"values":["net.tirasa.connid.bundles.kafka.serialization.SyncDeltaSerializer"],"overridable":false},{"schema":{"name":"valueDeserializerClassName","displayName":"Value deserializer class","helpMessage":"Deserializer class for value that implements the org.apache.kafka.common.serialization.Deserializer interface. Defaults to org.apache.kafka.common.serialization.StringDeserializer","type":"java.lang.String","required":true,"order":6,"confidential":false,"defaultValues":["org.apache.kafka.common.serialization.StringDeserializer"]},"values":["org.apache.kafka.common.serialization.StringDeserializer"],"overridable":false},{"schema":{"name":"accountTopic","displayName":"Topic to publish to and being subscribed to for object class __ACCOUNT__","helpMessage":"A topic is similar to a folder in a filesystem, and the events are the files in that folder.","type":"java.lang.String","required":false,"order":7,"confidential":false,"defaultValues":["__ACCOUNT__"]},"values":["account-provisioning"],"overridable":false},{"schema":{"name":"groupTopic","displayName":"Topic to publish to and being subscribed to for object class __GROUP__","helpMessage":"A topic is similar to a folder in a filesystem, and the events are the files in that folder.","type":"java.lang.String","required":false,"order":8,"confidential":false,"defaultValues":["__GROUP__"]},"values":["group-provisioning"],"overridable":false},{"schema":{"name":"allTopic","displayName":"Topic to publish to and being subscribed to for object class __ALL__","helpMessage":"A topic is similar to a folder in a filesystem, and the events are the files in that folder.","type":"java.lang.String","required":false,"order":9,"confidential":false,"defaultValues":["__ALL__"]},"values":["__ALL__"],"overridable":false},{"schema":{"name":"consumerPollMillis","displayName":"The maximum number of milliseconds to block while polling","helpMessage":"Polling returns immediately if there are records available or if the position advances past control records; otherwise, it will await the passed timeout: if the timeout expires, an empty record set will be returned.","type":"long","required":false,"order":10,"confidential":false,"defaultValues":[100]},"values":["100"],"overridable":false}]'
+                jsonConf='[{"schema":{"name":"bootstrapServers","displayName":"Bootstrap servers","helpMessage":"A list of host/port pairs used to establish the initial connection to the Kafka cluster","type":"java.lang.String","required":true,"order":1,"confidential":false,"defaultValues":[]},"values":["localhost:19092"],"overridable":false},{"schema":{"name":"clientId","displayName":"Client id","helpMessage":"Client id for subscription","type":"java.lang.String","required":true,"order":2,"confidential":false,"defaultValues":[]},"values":["syncope"],"overridable":false},{"schema":{"name":"consumerGroupId","displayName":"Consumer Group id","helpMessage":"A unique string that identifies the consumer group this consumer belongs to.","type":"java.lang.String","required":true,"order":3,"confidential":false,"defaultValues":[]},"values":["syncope"],"overridable":false},{"schema":{"name":"autoOffsetReset","displayName":"Auto offset reset","helpMessage":"What to do when there is no initial offset in Kafka or if the current offset does not exist any more on the server (e.g. because that data has been deleted); defaults to earliest in order to make sure the producer sent all messages before the consumer starts.","type":"java.lang.String","required":true,"order":4,"confidential":false,"defaultValues":["earliest"]},"values":["earliest"],"overridable":false},{"schema":{"name":"valueSerializerClassName","displayName":"Value serializer class","helpMessage":"Serializer class for value that implements the org.apache.kafka.common.serialization.Serializer interface. Defaults to net.tirasa.connid.bundles.kafka.serialization.SyncDeltaSerializer","type":"java.lang.String","required":true,"order":5,"confidential":false,"defaultValues":["net.tirasa.connid.bundles.kafka.serialization.SyncDeltaSerializer"]},"values":["net.tirasa.connid.bundles.kafka.serialization.SyncDeltaSerializer"],"overridable":false},{"schema":{"name":"valueDeserializerClassName","displayName":"Value deserializer class","helpMessage":"Deserializer class for value that implements the org.apache.kafka.common.serialization.Deserializer interface. Defaults to org.apache.kafka.common.serialization.StringDeserializer","type":"java.lang.String","required":true,"order":6,"confidential":false,"defaultValues":["org.apache.kafka.common.serialization.StringDeserializer"]},"values":["org.apache.kafka.common.serialization.StringDeserializer"],"overridable":false},{"schema":{"name":"accountTopic","displayName":"Topic to publish to and being subscribed to for object class __ACCOUNT__","helpMessage":"A topic is similar to a folder in a filesystem, and the events are the files in that folder.","type":"java.lang.String","required":false,"order":7,"confidential":false,"defaultValues":["__ACCOUNT__"]},"values":["account-provisioning"],"overridable":false},{"schema":{"name":"groupTopic","displayName":"Topic to publish to and being subscribed to for object class __GROUP__","helpMessage":"A topic is similar to a folder in a filesystem, and the events are the files in that folder.","type":"java.lang.String","required":false,"order":8,"confidential":false,"defaultValues":["__GROUP__"]},"values":["group-provisioning"],"overridable":false},{"schema":{"name":"allTopic","displayName":"Topic to publish to and being subscribed to for object class __ALL__","helpMessage":"A topic is similar to a folder in a filesystem, and the events are the files in that folder.","type":"java.lang.String","required":false,"order":9,"confidential":false,"defaultValues":["__ALL__"]},"values":["__ALL__"],"overridable":false},{"schema":{"name":"consumerPollMillis","displayName":"The maximum number of milliseconds to block while polling","helpMessage":"Polling returns immediately if there are records available or if the position advances past control records; otherwise, it will await the passed timeout: if the timeout expires, an empty record set will be returned.","type":"long","required":false,"order":10,"confidential":false,"defaultValues":[100]},"values":["5000"],"overridable":false}]'
                 poolConf='{"maxObjects":5,"minIdle":2,"maxIdle":3,"maxWait":10,"minEvictableIdleTimeMillis":5}'
                 capabilities='["DELETE","LIVE_SYNC","CREATE","UPDATE"]'/>
 

pom.xml

@@ -456,7 +456,7 @@ under the License.
 
     <openfga.version>v1</openfga.version>
 
-    <debezium.version>3.0</debezium.version>
+    <debezium.version>3.4</debezium.version>
 
     <commons-lang3.version>3.20.0</commons-lang3.version>
     <commons-jexl.version>3.6.2</commons-jexl.version>