aonamrata commented on issue #1849:
URL:
https://github.com/apache/camel-kafka-connector/issues/1849#issuecomment-6440374242
Thank you for creating this issue 🙏 .
**This is the full stack trace from the connector logs:**
```
2026-10-27 11:41:45.512 | [2026-10-27 06:11:45,509] ERROR
WorkerSourceTask{id=s3_source-0} Task threw an uncaught and unrecoverable
exception. Task is being killed and will not recover until manually restarted
(org.apache.kafka.connect.runtime.WorkerTask)
2026-10-27 11:41:45.512 | java.util.ServiceConfigurationError:
software.amazon.awssdk.http.SdkHttpService:
software.amazon.awssdk.http.apache.ApacheSdkHttpService not a subtype
2026-10-27 11:41:45.512 | at
java.base/java.util.ServiceLoader.fail(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNextService(Unknown
Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNext(Unknown
Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.ServiceLoader$2.hasNext(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.ServiceLoader$3.hasNext(Unknown Source)
2026-10-27 11:41:45.512 | at java.base/java.lang.Iterable.forEach(Unknown
Source)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.internal.http.loader.ClasspathSdkHttpServiceProvider.loadService(ClasspathSdkHttpServiceProvider.java:75)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.ReferencePipeline$3$1.accept(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.Spliterators$ArraySpliterator.tryAdvance(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.ReferencePipeline.forEachWithCancel(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.AbstractPipeline.copyIntoWithCancel(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.AbstractPipeline.copyInto(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.FindOps$FindOp.evaluateSequential(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.AbstractPipeline.evaluate(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.ReferencePipeline.findFirst(Unknown Source)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.internal.http.loader.SdkHttpServiceProviderChain.loadService(SdkHttpServiceProviderChain.java:44)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.internal.http.loader.CachingSdkHttpServiceProvider.loadService(CachingSdkHttpServiceProvider.java:46)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.internal.http.loader.DefaultSdkHttpClientBuilder.buildWithDefaults(DefaultSdkHttpClientBuilder.java:42)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.lambda$resolveSyncHttpClient$18(SdkDefaultClientBuilder.java:480)
2026-10-27 11:41:45.512 | at
java.base/java.util.Optional.orElseGet(Unknown Source)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.resolveSyncHttpClient(SdkDefaultClientBuilder.java:480)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.lambda$finalizeSyncConfiguration$5(SdkDefaultClientBuilder.java:316)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.utils.AttributeMap$DerivedValue.primeCache(AttributeMap.java:604)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.utils.AttributeMap$DerivedValue.get(AttributeMap.java:593)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.utils.AttributeMap$Builder.resolveValue(AttributeMap.java:400)
2026-10-27 11:41:45.512 | at
java.base/java.util.ArrayList.forEach(Unknown Source)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.utils.AttributeMap$Builder.build(AttributeMap.java:362)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.config.SdkClientConfiguration$Builder.build(SdkClientConfiguration.java:224)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.finalizeSyncConfiguration(SdkDefaultClientBuilder.java:318)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.syncClientConfiguration(SdkDefaultClientBuilder.java:207)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.services.s3.DefaultS3ClientBuilder.buildClient(DefaultS3ClientBuilder.java:37)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.services.s3.DefaultS3ClientBuilder.buildClient(DefaultS3ClientBuilder.java:26)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.build(SdkDefaultClientBuilder.java:173)
2026-10-27 11:41:45.512 | at
org.apache.camel.component.aws.common.AwsClientBuilderUtil.buildClient(AwsClientBuilderUtil.java:131)
2026-10-27 11:41:45.512 | at
org.apache.camel.component.aws2.s3.client.AWS2S3ClientFactory.getS3Client(AWS2S3ClientFactory.java:38)
2026-10-27 11:41:45.512 | at
org.apache.camel.component.aws2.s3.AWS2S3Endpoint.doStart(AWS2S3Endpoint.java:139)
2026-10-27 11:41:45.512 | at
org.apache.camel.support.service.BaseService.start(BaseService.java:132)
2026-10-27 11:41:45.512 | at
org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:129)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.RouteService.doWarmUp(RouteService.java:230)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:128)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:324)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:193)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.InternalRouteStartupManager.lambda$doStartOrResumeRoutes$0(InternalRouteStartupManager.java:129)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.lambda$startingRoutes$0(AbstractCamelContext.java:1193)
2026-10-27 11:41:45.512 | at
org.apache.camel.util.concurrent.ContextValueFactory.where(ContextValueFactory.java:65)
2026-10-27 11:41:45.512 | at
org.apache.camel.util.concurrent.ContextValue.where(ContextValue.java:177)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.startingRoutes(AbstractCamelContext.java:1191)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:117)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:3239)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2841)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2796)
2026-10-27 11:41:45.512 | at
org.apache.camel.support.service.BaseService.start(BaseService.java:132)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2375)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:214)
2026-10-27 11:41:45.512 | at
org.apache.camel.main.SimpleMain.doStart(SimpleMain.java:43)
2026-10-27 11:41:45.512 | at
org.apache.camel.support.service.BaseService.start(BaseService.java:132)
2026-10-27 11:41:45.512 | at
org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:191)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.initializeAndStart(AbstractWorkerSourceTask.java:288)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.WorkerTask.doStart(WorkerTask.java:191)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:242)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:298)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:83)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:251)
2026-10-27 11:41:45.512 | at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
2026-10-27 11:41:45.512 | at java.base/java.lang.Thread.run(Unknown
Source)
2026-10-27 11:41:45.512 | [2026-10-27 06:11:45,509] ERROR
WorkerSourceTask{id=s3_source-0} Task threw an uncaught and unrecoverable
exception. Task is being killed and will not recover until manually restarted
(org.apache.kafka.connect.runtime.WorkerTask)
2026-10-27 11:41:45.512 | java.util.ServiceConfigurationError:
software.amazon.awssdk.http.SdkHttpService:
software.amazon.awssdk.http.apache.ApacheSdkHttpService not a subtype
2026-10-27 11:41:45.512 | at
java.base/java.util.ServiceLoader.fail(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNextService(Unknown
Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.ServiceLoader$LazyClassPathLookupIterator.hasNext(Unknown
Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.ServiceLoader$2.hasNext(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.ServiceLoader$3.hasNext(Unknown Source)
2026-10-27 11:41:45.512 | at java.base/java.lang.Iterable.forEach(Unknown
Source)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.internal.http.loader.ClasspathSdkHttpServiceProvider.loadService(ClasspathSdkHttpServiceProvider.java:75)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.ReferencePipeline$3$1.accept(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.Spliterators$ArraySpliterator.tryAdvance(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.ReferencePipeline.forEachWithCancel(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.AbstractPipeline.copyIntoWithCancel(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.AbstractPipeline.copyInto(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.FindOps$FindOp.evaluateSequential(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.AbstractPipeline.evaluate(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.stream.ReferencePipeline.findFirst(Unknown Source)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.internal.http.loader.SdkHttpServiceProviderChain.loadService(SdkHttpServiceProviderChain.java:44)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.internal.http.loader.CachingSdkHttpServiceProvider.loadService(CachingSdkHttpServiceProvider.java:46)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.internal.http.loader.DefaultSdkHttpClientBuilder.buildWithDefaults(DefaultSdkHttpClientBuilder.java:42)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.lambda$resolveSyncHttpClient$18(SdkDefaultClientBuilder.java:480)
2026-10-27 11:41:45.512 | at
java.base/java.util.Optional.orElseGet(Unknown Source)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.resolveSyncHttpClient(SdkDefaultClientBuilder.java:480)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.lambda$finalizeSyncConfiguration$5(SdkDefaultClientBuilder.java:316)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.utils.AttributeMap$DerivedValue.primeCache(AttributeMap.java:604)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.utils.AttributeMap$DerivedValue.get(AttributeMap.java:593)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.utils.AttributeMap$Builder.resolveValue(AttributeMap.java:400)
2026-10-27 11:41:45.512 | at
java.base/java.util.ArrayList.forEach(Unknown Source)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.utils.AttributeMap$Builder.build(AttributeMap.java:362)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.config.SdkClientConfiguration$Builder.build(SdkClientConfiguration.java:224)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.finalizeSyncConfiguration(SdkDefaultClientBuilder.java:318)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.syncClientConfiguration(SdkDefaultClientBuilder.java:207)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.services.s3.DefaultS3ClientBuilder.buildClient(DefaultS3ClientBuilder.java:37)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.services.s3.DefaultS3ClientBuilder.buildClient(DefaultS3ClientBuilder.java:26)
2026-10-27 11:41:45.512 | at
software.amazon.awssdk.core.client.builder.SdkDefaultClientBuilder.build(SdkDefaultClientBuilder.java:173)
2026-10-27 11:41:45.512 | at
org.apache.camel.component.aws.common.AwsClientBuilderUtil.buildClient(AwsClientBuilderUtil.java:131)
2026-10-27 11:41:45.512 | at
org.apache.camel.component.aws2.s3.client.AWS2S3ClientFactory.getS3Client(AWS2S3ClientFactory.java:38)
2026-10-27 11:41:45.512 | at
org.apache.camel.component.aws2.s3.AWS2S3Endpoint.doStart(AWS2S3Endpoint.java:139)
2026-10-27 11:41:45.512 | at
org.apache.camel.support.service.BaseService.start(BaseService.java:132)
2026-10-27 11:41:45.512 | at
org.apache.camel.support.service.ServiceHelper.startService(ServiceHelper.java:129)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.RouteService.doWarmUp(RouteService.java:230)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:128)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:324)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:193)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.InternalRouteStartupManager.lambda$doStartOrResumeRoutes$0(InternalRouteStartupManager.java:129)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.lambda$startingRoutes$0(AbstractCamelContext.java:1193)
2026-10-27 11:41:45.512 | at
org.apache.camel.util.concurrent.ContextValueFactory.where(ContextValueFactory.java:65)
2026-10-27 11:41:45.512 | at
org.apache.camel.util.concurrent.ContextValue.where(ContextValue.java:177)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.startingRoutes(AbstractCamelContext.java:1191)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:117)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:3239)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2841)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2796)
2026-10-27 11:41:45.512 | at
org.apache.camel.support.service.BaseService.start(BaseService.java:132)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2375)
2026-10-27 11:41:45.512 | at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:214)
2026-10-27 11:41:45.512 | at
org.apache.camel.main.SimpleMain.doStart(SimpleMain.java:43)
2026-10-27 11:41:45.512 | at
org.apache.camel.support.service.BaseService.start(BaseService.java:132)
2026-10-27 11:41:45.512 | at
org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:191)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.initializeAndStart(AbstractWorkerSourceTask.java:288)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.WorkerTask.doStart(WorkerTask.java:191)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:242)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:298)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:83)
2026-10-27 11:41:45.512 | at
org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:251)
2026-10-27 11:41:45.512 | at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
2026-10-27 11:41:45.512 | at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
2026-10-27 11:41:45.512 | at java.base/java.lang.Thread.run(Unknown
Source)
```
**This is the connector configuration:**
```
{
connector.class:
"org.apache.camel.kafkaconnector.awss3source.CamelAwss3sourceSourceConnector",
tasks.max: "1",
topics: "event.s3.source",
camel.kamelet.aws-s3-source.bucketNameOrArn: "dev-kafka-connect",
camel.kamelet.aws-s3-source.autocloseBody: "false",
camel.kamelet.aws-s3-source.useDefaultCredentialsProvider: "true",
camel.kamelet.aws-s3-source.region: "us-east-1",
camel.kamelet.aws-s3-source.delay: "10000",
camel.kamelet.aws-s3-source.deleteAfterRead: "true",
value.converter.schemas.enable: "false",
name: "s3_source",
errors.tolerance: "all",
camel.kamelet.aws-s3-source.prefix: "",
value.converter: "org.apache.kafka.connect.converters.ByteArrayConverter",
key.converter: "org.apache.kafka.connect.storage.StringConverter"
}
```
and I am running the connector using [this docker
file](https://gist.github.com/aonamrata/616d62a45f35d4eac1a14ec55171b8b9) which
uses java 21.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
