You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Marco Carletti (Jira)" <ji...@apache.org> on 2025/05/05 10:43:00 UTC
[jira] [Updated] (CAMEL-22049) camel-aws2-kinesis: use created async client for KCL consumer
[ https://issues.apache.org/jira/browse/CAMEL-22049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Marco Carletti updated CAMEL-22049:
-----------------------------------
Description:
Since the [Kinesis2Endpoint|https://github.com/apache/camel/blob/main/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Endpoint.java#L68] already manages the instance of the _kinesisAsyncClient_ it would be nice to use this instance instead of to create a new one to bind to the registry due to the override of the [consumer configuration|https://github.com/apache/camel/blob/main/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/KclKinesis2Consumer.java#L88] that always use the configured client (even if it is null)
currently the endpoint
{code:none}
aws2-kinesis://mydatastream?region=myregion&useKclConsumers=true&asyncClient=true&useDefaultCredentialsProvider=true{code}
won't work without and instance of a _software.amazon.awssdk.services.kinesis.KinesisAsyncClient_ in the registry configured even if the camel component will create one
was:
Since the [Kinesis2Endpoint|https://github.com/apache/camel/blob/main/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Endpoint.java#L68] already manages the instance of the _kinesisAsyncClient_ it would be nice to use this instance instead of to create a new one to bind to the registry due to the override of the [consumer configuration|https://github.com/apache/camel/blob/main/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/KclKinesis2Consumer.java#L88] that always use the configured client (even if it is null)
currently the endpoint
{code:none}
aws2-kinesis://mydatastream?region=myregion&useKclConsumers=true&asyncClient=true&useDefaultCredentialsProvider=true"
{code}
won't work without and instance of a _software.amazon.awssdk.services.kinesis.KinesisAsyncClient_ in the registry configured even if the camel component will create one
> camel-aws2-kinesis: use created async client for KCL consumer
> -------------------------------------------------------------
>
> Key: CAMEL-22049
> URL: https://issues.apache.org/jira/browse/CAMEL-22049
> Project: Camel
> Issue Type: Improvement
> Components: camel-aws2-kinesis
> Affects Versions: 4.x
> Reporter: Marco Carletti
> Priority: Major
>
> Since the [Kinesis2Endpoint|https://github.com/apache/camel/blob/main/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Endpoint.java#L68] already manages the instance of the _kinesisAsyncClient_ it would be nice to use this instance instead of to create a new one to bind to the registry due to the override of the [consumer configuration|https://github.com/apache/camel/blob/main/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/KclKinesis2Consumer.java#L88] that always use the configured client (even if it is null)
> currently the endpoint
> {code:none}
> aws2-kinesis://mydatastream?region=myregion&useKclConsumers=true&asyncClient=true&useDefaultCredentialsProvider=true{code}
> won't work without and instance of a _software.amazon.awssdk.services.kinesis.KinesisAsyncClient_ in the registry configured even if the camel component will create one
--
This message was sent by Atlassian Jira
(v8.20.10#820010)