You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2025/02/25 17:29:57 UTC
(camel) branch main updated: CAMEL-21792 - camel-aws - KCL Kinesis Consumer fails with NPE when using custom async client (#17268)
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
The following commit(s) were added to refs/heads/main by this push:
new e0801cde940 CAMEL-21792 - camel-aws - KCL Kinesis Consumer fails with NPE when using custom async client (#17268)
e0801cde940 is described below
commit e0801cde940acd98af53ec189fac57068037146f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Feb 25 18:29:52 2025 +0100
CAMEL-21792 - camel-aws - KCL Kinesis Consumer fails with NPE when using custom async client (#17268)
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../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();