CAMEL-22796: camel-debezium - Upgrade to dbz 3.4.0 (#20577)

Author: davsclaus

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

@@ -35,24 +35,23 @@
 
 @Mojo(name = "generate-connector-config", defaultPhase = LifecyclePhase.GENERATE_SOURCES)
 public class GenerateConnectorConfigMojo extends AbstractMojo {
+
     @Parameter(defaultValue = "${project.build.directory}/generated-sources/connector-configurations")
     private File generatedSrcDir;
 
     /**
      * Debezium connector's class name, this has to be fully name with the package, e.g:
      * 'io.debezium.connector.mysql.MySqlConnector'
      */
-    @Parameter(
-               property = "camel.debezium.connector.class",
+    @Parameter(property = "camel.debezium.connector.class",
                required = true)
     private String connectorClassName;
 
     /**
      * Debezium connector's config class name, this has to be fully name with the package, e.g:
      * 'io.debezium.connector.mysql.MySqlConnectorConfig'
      */
-    @Parameter(
-               property = "camel.debezium.connector.config.class",
+    @Parameter(property = "camel.debezium.connector.config.class",
                required = true)
     private String connectorConfigClassName;
 

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

@@ -80,7 +80,10 @@ public String getDefaultValueAsStringLiteral() {
                 || fieldDef.type() == ConfigDef.Type.CLASS && defaultValue instanceof Class) {
             defaultValue = ConfigDef.convertToString(defaultValue, fieldDef.type());
         }
-        return String.format("\"%s\"", defaultValue);
+        // its converted to a string so we need to escape \. as \\.
+        String answer = String.format("\"%s\"", defaultValue);
+        answer = answer.replace("\\.", "\\\\.");
+        return answer;
     }
 
     public String getDefaultValueAsString() {
@@ -161,14 +164,20 @@ private String getDefaultValueWrappedInString(final ConfigDef.ConfigKey field) {
         if (defaultValue == null) {
             return null;
         }
+        String answer;
         if (fieldDef.type() == ConfigDef.Type.LIST
                 || fieldDef.type() == ConfigDef.Type.CLASS && defaultValue instanceof Class) {
-            return String.format("\"%s\"", ConfigDef.convertToString(defaultValue, fieldDef.type()));
+            answer = String.format("\"%s\"", ConfigDef.convertToString(defaultValue, fieldDef.type()));
         } else if (field.type() == ConfigDef.Type.STRING || field.type() == ConfigDef.Type.PASSWORD
                 || field.type() == ConfigDef.Type.CLASS) {
-            return String.format("\"%s\"", defaultValue);
+            answer = String.format("\"%s\"", defaultValue);
+        } else {
+            answer = defaultValue.toString();
+
         }
-        return defaultValue.toString();
+        // its converted to a string so we need to escape \. as \\.
+        answer = answer.replace("\\.", "\\\\.");
+        return answer;
     }
 
     private String removeNonAsciiChars(final String text) {

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

@@ -63,7 +63,7 @@ private ConnectorConfigGenerator(final SourceConnector connector, final Map<Stri
     /**
      * @deprecated use {@link #create(SourceConnector, Class, String)} instead
      */
-    @Deprecated(since = "3.9.0", forRemoval = true)
+    @Deprecated(since = "4.9.0", forRemoval = true)
     public static ConnectorConfigGenerator create(
             final SourceConnector connector, final Class<?> dbzConfigClass) {
         return create(connector, dbzConfigClass, null, Collections.emptySet(), Collections.emptyMap());
@@ -77,7 +77,7 @@ public static ConnectorConfigGenerator create(
     /**
      * @deprecated use {@link #create(SourceConnector, Class, String, Set)} instead
      */
-    @Deprecated(since = "3.9.0", forRemoval = true)
+    @Deprecated(since = "4.9.0", forRemoval = true)
     public static ConnectorConfigGenerator create(
             final SourceConnector connector, final Class<?> dbzConfigClass,
             final Set<String> requiredFields) {
@@ -93,7 +93,7 @@ public static ConnectorConfigGenerator create(
     /**
      * @deprecated use {@link #create(SourceConnector, Class, String, Map)} instead
      */
-    @Deprecated(since = "3.9.0", forRemoval = true)
+    @Deprecated(since = "4.9.0", forRemoval = true)
     public static ConnectorConfigGenerator create(
             final SourceConnector connector, final Class<?> dbzConfigClass,
             final Map<String, Object> overriddenDefaultValues) {

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

@@ -52,6 +52,8 @@ public boolean configure(CamelContext camelContext, Object obj, String name, Obj
         case "converters": getOrCreateConfiguration(target).setConverters(property(camelContext, java.lang.String.class, value)); return true;
         case "custommetrictags":
         case "customMetricTags": getOrCreateConfiguration(target).setCustomMetricTags(property(camelContext, java.lang.String.class, value)); return true;
+        case "customsanitizepattern":
+        case "customSanitizePattern": getOrCreateConfiguration(target).setCustomSanitizePattern(property(camelContext, java.lang.String.class, value)); return true;
         case "databasedbname":
         case "databaseDbname": getOrCreateConfiguration(target).setDatabaseDbname(property(camelContext, java.lang.String.class, value)); return true;
         case "databasehostname":
@@ -241,6 +243,8 @@ public Class<?> getOptionType(String name, boolean ignoreCase) {
         case "converters": return java.lang.String.class;
         case "custommetrictags":
         case "customMetricTags": return java.lang.String.class;
+        case "customsanitizepattern":
+        case "customSanitizePattern": return java.lang.String.class;
         case "databasedbname":
         case "databaseDbname": return java.lang.String.class;
         case "databasehostname":
@@ -431,6 +435,8 @@ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
         case "converters": return getOrCreateConfiguration(target).getConverters();
         case "custommetrictags":
         case "customMetricTags": return getOrCreateConfiguration(target).getCustomMetricTags();
+        case "customsanitizepattern":
+        case "customSanitizePattern": return getOrCreateConfiguration(target).getCustomSanitizePattern();
         case "databasedbname":
         case "databaseDbname": return getOrCreateConfiguration(target).getDatabaseDbname();
         case "databasehostname":