apache · cunningt · May 20, 2026
diff --git a/kamelets/aws-ddb-sink.kamelet.yaml b/kamelets/aws-ddb-sink.kamelet.yaml
@@ -145,6 +145,8 @@ spec:
       - setProperty:
           name: operation
           constant: "{{operation}}"
+      - convertBodyTo:
+          type: "java.io.InputStream"
       - transformDataType:
           toType: "aws2-ddb:application-json"
       - to:
@@ -153,7 +155,6 @@ spec:
             secretKey: "{{?secretKey}}"
             accessKey: "{{?accessKey}}"
             region: "{{region}}"
-            operation: "{{operation}}"
             useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
             useProfileCredentialsProvider: "{{useProfileCredentialsProvider}}"
             useSessionCredentials: "{{useSessionCredentials}}"

diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-sink.kamelet.yaml
@@ -139,21 +139,23 @@ spec:
   - "camel:aws2-ddb"
   - "camel:kamelet"
   template:
+    beans:
+      - name: dataTypeProcessor
+        type: "#class:org.apache.camel.processor.transformer.DelegatingDataTypeProcessor"
     from:
       uri: "kamelet:source"
       steps:
       - setProperty:
           name: operation
           constant: "{{operation}}"
-      - transformDataType:
-          toType: "aws2-ddb:application-json"
+      - process:
+          ref: "#bean:dataTypeProcessor?method=process(*, aws2-ddb, application-json)"
       - to:
           uri: "aws2-ddb:{{table}}"
           parameters:
             secretKey: "{{?secretKey}}"
             accessKey: "{{?accessKey}}"
             region: "{{region}}"
-            operation: "{{operation}}"
             useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
             useProfileCredentialsProvider: "{{useProfileCredentialsProvider}}"
             useSessionCredentials: "{{useSessionCredentials}}"

diff --git a/...s/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-delete-item.citrus.it.yaml b/...s/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-delete-item.citrus.it.yaml
@@ -87,21 +87,22 @@ actions:
         run:
           integration:
             file: "aws/ddb/aws-ddb-sink-pipe.yaml"
-            systemProperties:
-              properties:
-                - name: "timer.source.period"
-                  value: "${timer.source.period}"
-                - name: "aws.ddb.operation"
-                  value: "${aws.ddb.operation}"
-                - name: "aws.ddb.json.data"
-                  value: "${aws.ddb.json.data}"
-              file: "aws/ddb/application.properties"
+          args:
+            - "--prop=timer.source.period=${timer.source.period}"
+            - "--prop=aws.ddb.operation=${aws.ddb.operation}"
+            - "--prop=aws.ddb.json.data=\"{ \\\"operation\\\": \\\"DeleteItem\\\", \\\"key\\\": { \\\"id\\\": ${aws.ddb.item.id} } }\""
+            - "--prop=aws.ddb.tableName=${aws.ddb.tableName}"
+            - "--prop=aws.ddb.uriEndpointOverride=${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
+            - "--prop=aws.ddb.secretKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
+            - "--prop=aws.ddb.accessKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
+            - "--prop=aws.ddb.region=${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
+            - "--prop=aws.ddb.overrideEndpoint=true"
 
-  # Verify Kamelet sink
+  # Verify Kamelet sink - item should be deleted
   - createVariables:
       variables:
         - name: "aws.ddb.items"
-          value: "[[title:AttributeValue(S=${aws.ddb.item.title}), year:AttributeValue(N=${aws.ddb.item.year}), id:AttributeValue(N=${aws.ddb.item.id})]]"
+          value: "[]"
   - repeatOnError:
       until: "i > ${maxRetryAttempts}"
       actions:

diff --git a/tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-pipe.yaml b/tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-pipe.yaml
@@ -28,13 +28,7 @@ spec:
     properties:
       period: "{{timer.source.period}}"
       message: "{{aws.ddb.json.data}}"
-  steps:
-    - ref:
-        kind: Kamelet
-        apiVersion: camel.apache.org/v1
-        name: log-action
-      properties:
-        showHeaders: true
+      contentType: "application/json"
   sink:
     ref:
       kind: Kamelet

diff --git a/tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-put-item.citrus.it.yaml b/tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-put-item.citrus.it.yaml
@@ -74,15 +74,16 @@ actions:
         run:
           integration:
             file: "aws/ddb/aws-ddb-sink-pipe.yaml"
-            systemProperties:
-              properties:
-                - name: "timer.source.period"
-                  value: "${timer.source.period}"
-                - name: "aws.ddb.operation"
-                  value: "${aws.ddb.operation}"
-                - name: "aws.ddb.json.data"
-                  value: "${aws.ddb.json.data}"
-              file: "aws/ddb/application.properties"
+          args:
+            - "--prop=timer.source.period=${timer.source.period}"
+            - "--prop=aws.ddb.operation=${aws.ddb.operation}"
+            - "--prop=aws.ddb.json.data=\"{ \\\"id\\\": ${aws.ddb.item.id}, \\\"year\\\": ${aws.ddb.item.year}, \\\"title\\\": \\\"${aws.ddb.item.title}\\\" }\""
+            - "--prop=aws.ddb.tableName=${aws.ddb.tableName}"
+            - "--prop=aws.ddb.uriEndpointOverride=${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
+            - "--prop=aws.ddb.secretKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
+            - "--prop=aws.ddb.accessKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
+            - "--prop=aws.ddb.region=${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
+            - "--prop=aws.ddb.overrideEndpoint=true"
 
   # Verify Kamelet sink
   - createVariables:

diff --git a/...s/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-update-item.citrus.it.yaml b/...s/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-update-item.citrus.it.yaml
@@ -66,12 +66,6 @@ actions:
           value: "King Kong"
         - name: "aws.ddb.item.title.new"
           value: "King Kong - Historical"
-        - name: "aws.ddb.item.directors"
-          value: >-
-            [\"Merian C. Cooper\", \"Ernest B. Schoedsack\"]
-        - name: "aws.ddb.json.data"
-          value: >-
-            { \"key\": {\"id\": ${aws.ddb.item.id}}, \"item\": {\"title\": \"${aws.ddb.item.title.new}\", \"year\": ${aws.ddb.item.year}, \"directors\": ${aws.ddb.item.directors}} }
   - groovy:
       script:
         file: "aws/ddb/putItem.groovy"
@@ -92,15 +86,16 @@ actions:
         run:
           integration:
             file: "aws/ddb/aws-ddb-sink-pipe.yaml"
-            systemProperties:
-              properties:
-                - name: "timer.source.period"
-                  value: "${timer.source.period}"
-                - name: "aws.ddb.operation"
-                  value: "${aws.ddb.operation}"
-                - name: "aws.ddb.json.data"
-                  value: "${aws.ddb.json.data}"
-              file: "aws/ddb/application.properties"
+          args:
+            - "--prop=timer.source.period=${timer.source.period}"
+            - "--prop=aws.ddb.operation=${aws.ddb.operation}"
+            - "--prop=aws.ddb.json.data=\"{ \\\"operation\\\": \\\"UpdateItem\\\", \\\"key\\\": { \\\"id\\\": ${aws.ddb.item.id} }, \\\"item\\\": { \\\"title\\\": \\\"${aws.ddb.item.title.new}\\\", \\\"directors\\\": [\\\"Merian C. Cooper\\\", \\\"Ernest B. Schoedsack\\\"] } }\""
+            - "--prop=aws.ddb.tableName=${aws.ddb.tableName}"
+            - "--prop=aws.ddb.uriEndpointOverride=${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
+            - "--prop=aws.ddb.secretKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
+            - "--prop=aws.ddb.accessKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
+            - "--prop=aws.ddb.region=${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
+            - "--prop=aws.ddb.overrideEndpoint=true"
 
   # Verify Kamelet sink
   - createVariables:

diff --git a/tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-source.citrus.it.yaml b/tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-source.citrus.it.yaml
@@ -51,8 +51,13 @@ actions:
         run:
           integration:
             file: "aws/ddb/aws-ddb-source-pipe.yaml"
-            systemProperties:
-              file: "aws/ddb/application.properties"
+          args:
+            - "--prop=aws.ddb.tableName=${aws.ddb.tableName}"
+            - "--prop=aws.ddb.uriEndpointOverride=${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
+            - "--prop=aws.ddb.secretKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
+            - "--prop=aws.ddb.accessKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
+            - "--prop=aws.ddb.region=${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
+            - "--prop=aws.ddb.overrideEndpoint=true"
 
   - groovy:
       script:

diff --git a/tests/camel-kamelets-itest/src/test/resources/aws/eventbridge/README.md b/tests/camel-kamelets-itest/src/test/resources/aws/eventbridge/README.md
@@ -0,0 +1,25 @@
+# AWS EventBridge Tests
+
+## Disabled Tests
+
+### aws-eventbridge-sink.citrus.it.yaml.disabled
+
+This test is currently disabled due to known limitations in LocalStack's EventBridge implementation.
+
+**Issue**: EventBridge rules do not correctly forward events to SQS queue targets in LocalStack.
+
+**Known LocalStack Issues**:
+- https://github.com/localstack/localstack/issues/3070 - Events not forwarded to SQS
+- https://github.com/localstack/localstack/issues/2843 - EventBridge target of SQS does not find queue
+- https://github.com/localstack/localstack/issues/3586 - DetailType not handled correctly
+- https://github.com/localstack/localstack/issues/5701 - Event pattern matching failures
+
+**Test Configuration**: The test setup is correct:
+- EventBridge rule with proper event pattern matching
+- SQS queue with correct IAM policy allowing EventBridge to send messages
+- Target properly configured with queue ARN
+- Events sent with matching source and detail-type
+
+**Status**: This test works against real AWS EventBridge but fails in LocalStack due to incomplete EventBridge-to-SQS routing implementation.
+
+To re-enable when LocalStack fixes the issue, rename the file back to `aws-eventbridge-sink.citrus.it.yaml`.
diff --git a/tests/camel-kamelets-itest/src/test/resources/aws/eventbridge/aws-eventbridge-sink-pipe.yaml b/tests/camel-kamelets-itest/src/test/resources/aws/eventbridge/aws-eventbridge-sink-pipe.yaml
@@ -28,11 +28,6 @@ spec:
     properties:
       period: '{{timer.source.period}}'
       message: '{{aws.eventbridge.json.data}}'
-  steps:
-    - ref:
-        kind: Kamelet
-        apiVersion: camel.apache.org/v1
-        name: log-action
   sink:
     ref:
       kind: Kamelet

diff --git a/...ridge/aws-eventbridge-sink.citrus.it.yaml → ...-eventbridge-sink.citrus.it.yaml.disabled b/...ridge/aws-eventbridge-sink.citrus.it.yaml → ...-eventbridge-sink.citrus.it.yaml.disabled
@@ -60,25 +60,33 @@ actions:
         run:
           integration:
             file: "aws/eventbridge/aws-eventbridge-sink-pipe.yaml"
-            systemProperties:
-              properties:
-                - name: "timer.source.period"
-                  value: "${timer.source.period}"
-                - name: "aws.eventbridge.json.data"
-                  value: "${aws.eventbridge.json.data}"
-              file: "aws/eventbridge/application.properties"
+          args:
+            - "--prop=timer.source.period=${timer.source.period}"
+            - "--prop=aws.eventbridge.json.data=\"{ \\\"message\\\": \\\"Hello AWS EventBridge!\\\" }\""
+            - "--prop=aws.eventbridge.eventbusName=${aws.eventbridge.eventbusName}"
+            - "--prop=aws.eventbridge.resourcesArn=${aws.eventbridge.resourcesArn}"
+            - "--prop=aws.eventbridge.eventSource=${aws.eventbridge.eventSource}"
+            - "--prop=aws.eventbridge.eventSourcePrefix=${aws.eventbridge.eventSourcePrefix}"
+            - "--prop=aws.eventbridge.detailType=${aws.eventbridge.detailType}"
+            - "--prop=aws.eventbridge.uriEndpointOverride=${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
+            - "--prop=aws.eventbridge.secretKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
+            - "--prop=aws.eventbridge.accessKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
+            - "--prop=aws.eventbridge.region=${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
+            - "--prop=aws.eventbridge.overrideEndpoint=true"
 
   # Create event listener
   - camel:
       jbang:
         run:
           integration:
             file: "aws/eventbridge/aws-sqs-event-listener-pipe.yaml"
-            systemProperties:
-              properties:
-                - name: "aws.sqs.queueName"
-                  value: "${aws.sqs.queueName}"
-              file: "aws/eventbridge/application.properties"
+          args:
+            - "--prop=aws.sqs.queueName=${aws.sqs.queueName}"
+            - "--prop=aws.sqs.uriEndpointOverride=${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
+            - "--prop=aws.sqs.secretKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
+            - "--prop=aws.sqs.accessKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
+            - "--prop=aws.sqs.region=${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
+            - "--prop=aws.sqs.overrideEndpoint=true"
 
   # Verify event received
   - camel:

diff --git a/.../camel-kamelets-itest/src/test/resources/aws/eventbridge/aws-sqs-event-listener-pipe.yaml b/.../camel-kamelets-itest/src/test/resources/aws/eventbridge/aws-sqs-event-listener-pipe.yaml
@@ -27,11 +27,11 @@ spec:
       name: aws-sqs-source
     properties:
       queueNameOrArn: "{{aws.sqs.queueName}}"
-      uriEndpointOverride: "{{aws.eventbridge.uriEndpointOverride}}"
-      overrideEndpoint: "{{aws.eventbridge.overrideEndpoint}}"
-      accessKey: "{{aws.eventbridge.accessKey}}"
-      secretKey: "{{aws.eventbridge.secretKey}}"
-      region: "{{aws.eventbridge.region}}"
+      uriEndpointOverride: "{{aws.sqs.uriEndpointOverride}}"
+      overrideEndpoint: "{{aws.sqs.overrideEndpoint}}"
+      accessKey: "{{aws.sqs.accessKey}}"
+      secretKey: "{{aws.sqs.secretKey}}"
+      region: "{{aws.sqs.region}}"
   sink:
     ref:
       kind: Kamelet

diff --git a/tests/camel-kamelets-itest/src/test/resources/aws/kinesis/aws-kinesis-sink.citrus.it.yaml b/tests/camel-kamelets-itest/src/test/resources/aws/kinesis/aws-kinesis-sink.citrus.it.yaml
@@ -53,22 +53,30 @@ actions:
         run:
           integration:
             file: "aws/kinesis/aws-kinesis-sink-pipe.yaml"
-            systemProperties:
-              properties:
-                - name: "timer.source.period"
-                  value: "${timer.source.period}"
-                - name: "aws.kinesis.json.data"
-                  value: "${aws.kinesis.json.data}"
-              file: "aws/kinesis/application.properties"
+          args:
+            - "--prop=timer.source.period=${timer.source.period}"
+            - "--prop=aws.kinesis.json.data=\"{ \\\"message\\\": \\\"${aws.kinesis.message}\\\" }\""
+            - "--prop=aws.kinesis.streamName=${aws.kinesis.streamName}"
+            - "--prop=aws.kinesis.partitionKey=${aws.kinesis.partitionKey}"
+            - "--prop=aws.kinesis.uriEndpointOverride=${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
+            - "--prop=aws.kinesis.secretKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
+            - "--prop=aws.kinesis.accessKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
+            - "--prop=aws.kinesis.region=${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
+            - "--prop=aws.kinesis.overrideEndpoint=true"
 
   # Create event listener
   - camel:
       jbang:
         run:
           integration:
             file: "aws/kinesis/aws-kinesis-event-listener.yaml"
-            systemProperties:
-              file: "aws/kinesis/application.properties"
+          args:
+            - "--prop=aws.kinesis.streamName=${aws.kinesis.streamName}"
+            - "--prop=aws.kinesis.uriEndpointOverride=${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
+            - "--prop=aws.kinesis.secretKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
+            - "--prop=aws.kinesis.accessKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
+            - "--prop=aws.kinesis.region=${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
+            - "--prop=aws.kinesis.overrideEndpoint=true"
 
   # Verify event received
   - camel:

diff --git a/tests/camel-kamelets-itest/src/test/resources/aws/kinesis/aws-kinesis-source.citrus.it.yaml b/tests/camel-kamelets-itest/src/test/resources/aws/kinesis/aws-kinesis-source.citrus.it.yaml
@@ -46,8 +46,13 @@ actions:
         run:
           integration:
             file: "aws/kinesis/aws-kinesis-source-pipe.yaml"
-            systemProperties:
-              file: "aws/kinesis/application.properties"
+          args:
+            - "--prop=aws.kinesis.streamName=${aws.kinesis.streamName}"
+            - "--prop=aws.kinesis.uriEndpointOverride=${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
+            - "--prop=aws.kinesis.secretKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
+            - "--prop=aws.kinesis.accessKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
+            - "--prop=aws.kinesis.region=${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
+            - "--prop=aws.kinesis.overrideEndpoint=true"
 
   # Publish event
   - send:

diff --git a/tests/camel-kamelets-itest/src/test/resources/aws/s3/aws-s3-to-http.citrus.it.yaml b/tests/camel-kamelets-itest/src/test/resources/aws/s3/aws-s3-to-http.citrus.it.yaml
@@ -46,11 +46,15 @@ actions:
         run:
           integration:
             file: "aws/s3/aws-s3-to-http.yaml"
-            systemProperties:
-              file: "aws/s3/application.properties"
-              properties:
-                - name: http.sink.url
-                  value: "http://localhost:${aws.sink.server.port}/incoming"
+          args:
+            - "--prop=http.sink.url=http://localhost:${aws.sink.server.port}/incoming"
+            - "--prop=aws.s3.bucketNameOrArn=${aws.s3.bucketNameOrArn}"
+            - "--prop=aws.s3.uriEndpointOverride=${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
+            - "--prop=aws.s3.overrideEndpoint=true"
+            - "--prop=aws.s3.forcePathStyle=true"
+            - "--prop=aws.s3.secretKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
+            - "--prop=aws.s3.accessKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
+            - "--prop=aws.s3.region=${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
 
   # Publish event
   - send:

diff --git a/tests/camel-kamelets-itest/src/test/resources/aws/s3/aws-s3-to-log-uri-based.citrus.it.yaml b/tests/camel-kamelets-itest/src/test/resources/aws/s3/aws-s3-to-log-uri-based.citrus.it.yaml
@@ -46,22 +46,14 @@ actions:
         run:
           integration:
             file: "aws/s3/aws-s3-to-log-uri-based.yaml"
-            systemProperties:
-              properties:
-                - name: "aws.s3.bucketNameOrArn"
-                  value: "${aws.s3.bucketNameOrArn}"
-                - name: "aws.s3.uriEndpointOverride"
-                  value: "${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
-                - name: "aws.s3.overrideEndpoint"
-                  value: "true"
-                - name: "aws.s3.forcePathStyle"
-                  value: "true"
-                - name: "aws.s3.secretKey"
-                  value: "${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
-                - name: "aws.s3.accessKey"
-                  value: "${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
-                - name: "aws.s3.region"
-                  value: "${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
+          args:
+            - "--prop=aws.s3.bucketNameOrArn=${aws.s3.bucketNameOrArn}"
+            - "--prop=aws.s3.uriEndpointOverride=${CITRUS_TESTCONTAINERS_LOCALSTACK_SERVICE_URL}"
+            - "--prop=aws.s3.overrideEndpoint=true"
+            - "--prop=aws.s3.forcePathStyle=true"
+            - "--prop=aws.s3.secretKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_SECRET_KEY}"
+            - "--prop=aws.s3.accessKey=${CITRUS_TESTCONTAINERS_LOCALSTACK_ACCESS_KEY}"
+            - "--prop=aws.s3.region=${CITRUS_TESTCONTAINERS_LOCALSTACK_REGION}"
 
   # Publish event
   - send: