This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit eec0e59a19c1206410a42b5cfafe3ba9a195540d Author: Andrea Cosentino <[email protected]> AuthorDate: Sat Feb 22 14:00:00 2025 +0100 CAMEL-21792 - camel-aws - KCL Kinesis Consumer fails with NPE when using custom async client (#17268) Signed-off-by: Andrea Cosentino <[email protected]> --- .../org/apache/camel/component/aws2/kinesis/KclKinesis2Consumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/KclKinesis2Consumer.java b/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/KclKinesis2Consumer.java index 79deb321ae7..929cbf40074 100644 --- a/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/KclKinesis2Consumer.java +++ b/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/KclKinesis2Consumer.java @@ -85,7 +85,7 @@ public class KclKinesis2Consumer extends DefaultConsumer { LOG.debug("Starting KCL Consumer"); DynamoDbAsyncClient dynamoDbAsyncClient = null; CloudWatchAsyncClient cloudWatchAsyncClient = null; - KinesisAsyncClient kinesisAsyncClient = getEndpoint().getAsyncClient(); + KinesisAsyncClient kinesisAsyncClient = getEndpoint().getConfiguration().getAmazonKinesisAsyncClient(); Kinesis2Configuration configuration = getEndpoint().getConfiguration(); if (ObjectHelper.isEmpty(getEndpoint().getConfiguration().getDynamoDbAsyncClient())) { DynamoDbAsyncClientBuilder clientBuilder = DynamoDbAsyncClient.builder();
