[GitHub] [camel-kafka-connector] ruchirvaninasdaq commented on issue #95: Not able to run aws s3 source connector

[GitBox]

ruchirvaninasdaq commented on issue #95: Not able to run aws s3 source 
connector 
URL: 
https://github.com/apache/camel-kafka-connector/issues/95#issuecomment-591014283
 
 
   Now, I am getting the following error: 
   
   ```
   2020-02-25 19:00:30,364 INFO [Worker clientId=connect-1, 
groupId=connect-cluster] Finished starting connectors and tasks 
(org.apache.kafka.connect.runtime.distributed.DistributedHerder) 
[DistributedHerder-connect-1]
   2020-02-25 19:00:30,370 INFO CamelSourceConnectorConfig values:
           camel.source.camelMessageHeaderKey = null
           camel.source.component = null
           camel.source.kafka.topic = s3-topic
           camel.source.maxBatchPollSize = 1000
           camel.source.maxPollDuration = 10000
           camel.source.pollingConsumerBlockTimeout = 0
           camel.source.pollingConsumerBlockWhenFull = true
           camel.source.pollingConsumerQueueSize = 1000
           camel.source.unmarshal = null
           camel.source.url = aws-s3://{bucketName}?autocloseBody=false
    (org.apache.camel.kafkaconnector.CamelSourceConnectorConfig) 
[task-thread-s3-connector-camel-0]
   2020-02-25 19:00:30,375 INFO WorkerSourceTask{id=s3-connector-camel-0} 
Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) 
[task-thread-s3-connector-camel-0]
   2020-02-25 19:00:30,375 INFO WorkerSourceTask{id=s3-connector-camel-0} 
flushing 0 outstanding messages for offset commit 
(org.apache.kafka.connect.runtime.WorkerSourceTask) 
[task-thread-s3-connector-camel-0]
   2020-02-25 19:00:30,377 ERROR WorkerSourceTask{id=s3-connector-camel-0} Task 
threw an uncaught and unrecoverable exception 
(org.apache.kafka.connect.runtime.WorkerTask) [task-thread-s3-connector-camel-0]
   java.lang.NoClassDefFoundError: org/apache/camel/CamelContext
           at 
org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:89)
           at 
org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:199)
           at 
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
           at 
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
           at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
           at java.util.concurrent.FutureTask.run(FutureTask.java:266)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   Caused by: java.lang.ClassNotFoundException: org.apache.camel.CamelContext
           at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
           at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
           at 
org.apache.kafka.connect.runtime.isolation.PluginClassLoader.loadClass(PluginClassLoader.java:104)
           at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
           ... 9 more
   2020-02-25 19:00:30,396 ERROR WorkerSourceTask{id=s3-connector-camel-0} Task 
is being killed and will not recover until manually restarted 
(org.apache.kafka.connect.runtime.WorkerTask) [task-thread-s3-connector-camel-0]
   2020-02-25 19:00:30,396 INFO Stopping CamelSourceTask connector task 
(org.apache.camel.kafkaconnector.CamelSourceTask) 
[task-thread-s3-connector-camel-0]
   2020-02-25 19:00:30,397 WARN Could not stop task 
(org.apache.kafka.connect.runtime.WorkerSourceTask) 
[task-thread-s3-connector-camel-0]
   java.lang.NoClassDefFoundError: org/apache/camel/PollingConsumer
           at 
org.apache.camel.kafkaconnector.CamelSourceTask.stop(CamelSourceTask.java:156)
           at 
org.apache.kafka.connect.runtime.WorkerSourceTask.tryStop(WorkerSourceTask.java:187)
           at 
org.apache.kafka.connect.runtime.WorkerSourceTask.close(WorkerSourceTask.java:151)
           at 
org.apache.kafka.connect.runtime.WorkerTask.doClose(WorkerTask.java:156)
           at 
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:183)
           at 
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
           at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
           at java.util.concurrent.FutureTask.run(FutureTask.java:266)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   Caused by: java.lang.ClassNotFoundException: org.apache.camel.PollingConsumer
           at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
           at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
           at 
org.apache.kafka.connect.runtime.isolation.PluginClassLoader.loadClass(PluginClassLoader.java:104)
           at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
           ... 11 more
   ```

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services