CAMEL-19988

core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/IntrospectionSupport.java

@@ -598,6 +598,7 @@ static boolean setProperty(
                 }
             }
 
+            boolean myself = false;
             try {
                 try {
                     // If the type is null or it matches the needed type, just use the value directly
@@ -620,6 +621,8 @@ static boolean setProperty(
                         if ((parameterType == Boolean.class || parameterType == boolean.class) && ref instanceof String) {
                             String val = (String) ref;
                             if (!val.equalsIgnoreCase("true") && !val.equalsIgnoreCase("false")) {
+                                // this is our self
+                                myself = true;
                                 throw new IllegalArgumentException(
                                         "Cannot convert the String value: " + ref + " to type: " + parameterType
                                                                    + " as the value is not true or false");
@@ -650,7 +653,14 @@ static boolean setProperty(
                     }
                 }
                 // ignore exceptions as there could be another setter method where we could type convert successfully
-            } catch (SecurityException | NoTypeConversionAvailableException | IllegalArgumentException e) {
+            } catch (IllegalArgumentException e) {
+                // this can be either our own or while trying to set the property on the bean that fails in the 3rd party component
+                if (myself) {
+                    typeConversionFailed = e;
+                } else {
+                    throw e;
+                }
+            } catch (SecurityException | NoTypeConversionAvailableException e) {
                 typeConversionFailed = e;
             }
 

dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java

@@ -463,7 +463,7 @@ static org.apache.camel.builder.component.dsl.Aws2StsComponentBuilderFactory.Aws
     }
     /**
      * AWS Timestream (camel-aws2-timestream)
-     * A Camel Amazon Web Services TimeStream component
+     * Write records and execute queries on AWS time-series database
      * 
      * Category: cloud,database
      * Since: 4.1
@@ -1627,6 +1627,7 @@ static org.apache.camel.builder.component.dsl.GoogleStorageComponentBuilderFacto
      * 
      * @return the dsl builder
      */
+    @Deprecated
     static org.apache.camel.builder.component.dsl.GrapeComponentBuilderFactory.GrapeComponentBuilder grape() {
         return org.apache.camel.builder.component.dsl.GrapeComponentBuilderFactory.grape();
     }

dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2TimestreamComponentBuilderFactory.java

@@ -23,7 +23,7 @@
 import org.apache.camel.component.aws2.timestream.Timestream2Component;
 
 /**
- * A Camel Amazon Web Services TimeStream component
+ * Write records and execute queries on AWS time-series database
  * 
  * Generated by camel-package-maven-plugin - do not edit this file!
  */
@@ -32,7 +32,7 @@ public interface Aws2TimestreamComponentBuilderFactory {
 
     /**
      * AWS Timestream (camel-aws2-timestream)
-     * A Camel Amazon Web Services TimeStream component
+     * Write records and execute queries on AWS time-series database
      * 
      * Category: cloud,database
      * Since: 4.1

dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/GrapeComponentBuilderFactory.java

@@ -42,6 +42,7 @@ public interface GrapeComponentBuilderFactory {
      * 
      * @return the dsl builder
      */
+    @Deprecated
     static GrapeComponentBuilder grape() {
         return new GrapeComponentBuilderImpl();
     }

dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/KafkaComponentBuilderFactory.java

@@ -653,6 +653,27 @@ default KafkaComponentBuilder pollTimeoutMs(java.lang.Long pollTimeoutMs) {
             doSetProperty("pollTimeoutMs", pollTimeoutMs);
             return this;
         }
+        /**
+         * Whether to eager validate that broker host:port is valid and can be
+         * DNS resolved to known host during starting this consumer. If the
+         * validation fails then an exception is thrown which makes Camel fail
+         * fast. Disabling this will postpone the validation after the consumer
+         * is started, and Camel will keep re-connecting in case of validation
+         * or DNS resolution error.
+         * 
+         * The option is a: <code>boolean</code> type.
+         * 
+         * Default: true
+         * Group: consumer
+         * 
+         * @param preValidateHostAndPort the value to set
+         * @return the dsl builder
+         */
+        default KafkaComponentBuilder preValidateHostAndPort(
+                boolean preValidateHostAndPort) {
+            doSetProperty("preValidateHostAndPort", preValidateHostAndPort);
+            return this;
+        }
         /**
          * Set if KafkaConsumer will read from the beginning or the end on
          * startup: SeekPolicy.BEGINNING: read from the beginning.
@@ -2234,6 +2255,7 @@ protected boolean setPropertyOnComponent(
             case "partitionAssignor": getOrCreateConfiguration((KafkaComponent) component).setPartitionAssignor((java.lang.String) value); return true;
             case "pollOnError": getOrCreateConfiguration((KafkaComponent) component).setPollOnError((org.apache.camel.component.kafka.PollOnError) value); return true;
             case "pollTimeoutMs": getOrCreateConfiguration((KafkaComponent) component).setPollTimeoutMs((java.lang.Long) value); return true;
+            case "preValidateHostAndPort": getOrCreateConfiguration((KafkaComponent) component).setPreValidateHostAndPort((boolean) value); return true;
             case "seekTo": getOrCreateConfiguration((KafkaComponent) component).setSeekTo((org.apache.camel.component.kafka.SeekPolicy) value); return true;
             case "sessionTimeoutMs": getOrCreateConfiguration((KafkaComponent) component).setSessionTimeoutMs((java.lang.Integer) value); return true;
             case "specificAvroReader": getOrCreateConfiguration((KafkaComponent) component).setSpecificAvroReader((boolean) value); return true;