Fixed DDB Stream transform prefix for event source (#13628)

Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
apache · Mar 27, 2024 · ff63db2 · ff63db2
1 parent 70b3837
commit ff63db2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...che/camel/component/aws2/ddbstream/transform/Ddb2StreamCloudEventDataTypeTransformer.java b/...che/camel/component/aws2/ddbstream/transform/Ddb2StreamCloudEventDataTypeTransformer.java
@@ -46,7 +46,7 @@ public void transform(Message message, DataType fromType, DataType toType) {
 
         if (message.getHeaders().containsKey(Ddb2StreamConstants.EVENT_SOURCE)) {
             headers.put(CloudEvent.CAMEL_CLOUD_EVENT_SOURCE,
-                    "aws.s3.ddbstream." + message.getHeader(Ddb2StreamConstants.EVENT_SOURCE, String.class));
+                    "aws.ddbstream." + message.getHeader(Ddb2StreamConstants.EVENT_SOURCE, String.class));
         }
 
         headers.put(CloudEvent.CAMEL_CLOUD_EVENT_SUBJECT, message.getHeader(Ddb2StreamConstants.EVENT_ID, String.class));