This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 0cbddff2dd6a5f787eae4528bcedc53ef67a6d19 Author: Andrea Cosentino <[email protected]> AuthorDate: Fri Apr 24 11:20:31 2020 +0200 Camel-AWS2-MSK: Added example for pojoRequest --- .../camel-aws2-msk/src/main/docs/aws2-msk-component.adoc | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/components/camel-aws2-msk/src/main/docs/aws2-msk-component.adoc b/components/camel-aws2-msk/src/main/docs/aws2-msk-component.adoc index 82bcb5f..bee8ade 100644 --- a/components/camel-aws2-msk/src/main/docs/aws2-msk-component.adoc +++ b/components/camel-aws2-msk/src/main/docs/aws2-msk-component.adoc @@ -162,6 +162,19 @@ The component is capable of detecting the presence of an KafkaClient bean into t If it's the only instance of that type it will be used as client and you won't have to define it as uri parameter. This may be really useful for smarter configuration of the endpoint. +== Using a POJO as body + +Sometimes build an AWS Request can be complex, because of multiple options. We introduce the possibility to use a POJO as body. +In AWS MSK there are multiple operations you can submit, as an example for List clusters request, you can do something like: + +------------------------------------------------------------------------------------------------------ +from("direct:createUser") + .setBody(ListClustersRequest.builder().maxResults(10).build()) + .to("aws2-msk://test?mskClient=#amazonMskClient&operation=listClusters&pojoRequest=true") +------------------------------------------------------------------------------------------------------ + +In this way you'll pass the request directly without the need of passing headers and options specifically related to this operation. + Dependencies Maven users will need to add the following dependency to their pom.xml.
