Adapt to Debezium upgrade 3.5.0

- regen
- adapt code for deprecated fields

Signed-off-by: Aurélien Pupier <apupier@ibm.com>

Author: apupier

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-db2.json

@@ -76,7 +76,19 @@ private static Set<String> getDeprecatedFieldsFromConfigClass(final Class<?> con
 
     private static String retrieveDbzFieldWithReflection(final java.lang.reflect.Field reflectionField) {
         try {
-            return ((Field) reflectionField.get(null)).name();
+            Object object = reflectionField.get(null);
+            if (object instanceof Field field) {
+                return field.name();
+            } else if (object instanceof String fieldString) {
+                String removedDotAndCapitalize = Stream
+                        .of(fieldString.split("."))
+                        .map(field -> StringUtils.capitalize(field))
+                        .collect(Collectors.joining(""));
+                return StringUtils.uncapitalize(removedDotAndCapitalize);
+            } else {
+                throw new IllegalArgumentException(
+                        "Error occurred in field : " + reflectionField.getName() + " retrieved value is " + object);
+            }
         } catch (IllegalAccessException e) {
             throw new IllegalArgumentException("Error occurred in field : " + reflectionField.getName());
         }

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mongodb.json

@@ -176,6 +176,8 @@ public boolean configure(CamelContext camelContext, Object obj, String name, Obj
         case "snapshotIncludeCollectionList": getOrCreateConfiguration(target).setSnapshotIncludeCollectionList(property(camelContext, java.lang.String.class, value)); return true;
         case "snapshotlocktimeoutms":
         case "snapshotLockTimeoutMs": getOrCreateConfiguration(target).setSnapshotLockTimeoutMs(property(camelContext, java.time.Duration.class, value).toMillis()); return true;
+        case "snapshotmaxthreadsmultiplier":
+        case "snapshotMaxThreadsMultiplier": getOrCreateConfiguration(target).setSnapshotMaxThreadsMultiplier(property(camelContext, int.class, value)); return true;
         case "snapshotmode":
         case "snapshotMode": getOrCreateConfiguration(target).setSnapshotMode(property(camelContext, java.lang.String.class, value)); return true;
         case "snapshotmodeconfigurationbasedsnapshotdata":
@@ -367,6 +369,8 @@ public Class<?> getOptionType(String name, boolean ignoreCase) {
         case "snapshotIncludeCollectionList": return java.lang.String.class;
         case "snapshotlocktimeoutms":
         case "snapshotLockTimeoutMs": return long.class;
+        case "snapshotmaxthreadsmultiplier":
+        case "snapshotMaxThreadsMultiplier": return int.class;
         case "snapshotmode":
         case "snapshotMode": return java.lang.String.class;
         case "snapshotmodeconfigurationbasedsnapshotdata":
@@ -559,6 +563,8 @@ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
         case "snapshotIncludeCollectionList": return getOrCreateConfiguration(target).getSnapshotIncludeCollectionList();
         case "snapshotlocktimeoutms":
         case "snapshotLockTimeoutMs": return getOrCreateConfiguration(target).getSnapshotLockTimeoutMs();
+        case "snapshotmaxthreadsmultiplier":
+        case "snapshotMaxThreadsMultiplier": return getOrCreateConfiguration(target).getSnapshotMaxThreadsMultiplier();
         case "snapshotmode":
         case "snapshotMode": return getOrCreateConfiguration(target).getSnapshotMode();
         case "snapshotmodeconfigurationbasedsnapshotdata":

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mysql.json

@@ -170,6 +170,8 @@ public boolean configure(CamelContext camelContext, Object obj, String name, Obj
         case "snapshotIncludeCollectionList": target.getConfiguration().setSnapshotIncludeCollectionList(property(camelContext, java.lang.String.class, value)); return true;
         case "snapshotlocktimeoutms":
         case "snapshotLockTimeoutMs": target.getConfiguration().setSnapshotLockTimeoutMs(property(camelContext, java.time.Duration.class, value).toMillis()); return true;
+        case "snapshotmaxthreadsmultiplier":
+        case "snapshotMaxThreadsMultiplier": target.getConfiguration().setSnapshotMaxThreadsMultiplier(property(camelContext, int.class, value)); return true;
         case "snapshotmode":
         case "snapshotMode": target.getConfiguration().setSnapshotMode(property(camelContext, java.lang.String.class, value)); return true;
         case "snapshotmodeconfigurationbasedsnapshotdata":
@@ -362,6 +364,8 @@ public Class<?> getOptionType(String name, boolean ignoreCase) {
         case "snapshotIncludeCollectionList": return java.lang.String.class;
         case "snapshotlocktimeoutms":
         case "snapshotLockTimeoutMs": return long.class;
+        case "snapshotmaxthreadsmultiplier":
+        case "snapshotMaxThreadsMultiplier": return int.class;
         case "snapshotmode":
         case "snapshotMode": return java.lang.String.class;
         case "snapshotmodeconfigurationbasedsnapshotdata":
@@ -555,6 +559,8 @@ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
         case "snapshotIncludeCollectionList": return target.getConfiguration().getSnapshotIncludeCollectionList();
         case "snapshotlocktimeoutms":
         case "snapshotLockTimeoutMs": return target.getConfiguration().getSnapshotLockTimeoutMs();
+        case "snapshotmaxthreadsmultiplier":
+        case "snapshotMaxThreadsMultiplier": return target.getConfiguration().getSnapshotMaxThreadsMultiplier();
         case "snapshotmode":
         case "snapshotMode": return target.getConfiguration().getSnapshotMode();
         case "snapshotmodeconfigurationbasedsnapshotdata":

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json

@@ -23,7 +23,7 @@ public class DebeziumDb2EndpointUriFactory extends org.apache.camel.support.comp
     private static final Set<String> SECRET_PROPERTY_NAMES;
     private static final Map<String, String> MULTI_VALUE_PREFIXES;
     static {
-        Set<String> props = new HashSet<>(94);
+        Set<String> props = new HashSet<>(95);
         props.add("additionalProperties");
         props.add("bridgeErrorHandler");
         props.add("cdcChangeTablesSchema");
@@ -99,6 +99,7 @@ public class DebeziumDb2EndpointUriFactory extends org.apache.camel.support.comp
         props.add("snapshotFetchSize");
         props.add("snapshotIncludeCollectionList");
         props.add("snapshotLockTimeoutMs");
+        props.add("snapshotMaxThreadsMultiplier");
         props.add("snapshotMode");
         props.add("snapshotModeConfigurationBasedSnapshotData");
         props.add("snapshotModeConfigurationBasedSnapshotOnDataError");