topic Talend Cloud- Unable to send MessageGroupId and other message attributes to AWS SNS FIFO in Talend Studio

Talend Cloud- Unable to send MessageGroupId and other message attributes to AWS SNS FIFO

JDoe1627570841 — Fri, 15 Nov 2024 23:47:10 GMT

I need to send the payload body and message attributes to SNS FIFO using Talend route, but I am unable to send it because of the error on "MessageGroupId" which is com.amazonaws.services.sns.model.InvalidParameterException: Invalid parameter: The MessageGroupId parameter is required for FIFO topics.

In cAWSSNS component's basic or advance setting, there is no option to send the

MessageGroupId or other attributes.

Tried below options:

Passed the

MessageGroupId into a payload body as Message attributes, but it is not working.

Tried setting exchangeId, still no success.

Please help me out if anyone knows the solution for this issue.

Re: Talend Cloud- Unable to send MessageGroupId and other message attributes to AWS SNS FIFO

jeoste — Wed, 28 Jun 2023 14:44:43 GMT

Hi,

I had same problem, here's the solution :

In your Talend Route, inside the cAWSSNS component, Advanced settings, add "messageGroupIdStrategy" for Name and "useConstant" as value.

Make sure your cAWSSQS is a FIFO queue and you have added "Message GroupId Strategy (for FIFO queue)" with the value "useConstant" too.

I found this solution digging the java code of the route, since the error is mentioning "MessageGroupId" that's not the right answer from Camel documentation (https://camel.apache.org/components/3.20.x/aws2-sns-component.html)

Regards