Marco Carletti created CAMEL-22049:
--------------------------------------
Summary: 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
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)
