mgenereu commented on issue #361:
URL:
https://github.com/apache/camel-kafka-connector/issues/361#issuecomment-668771783
Here's the whole error message as well:
```
org.apache.kafka.connect.errors.ConnectException: Failed to create and start
Camel context
at
org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:103)
at
org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:202)
at
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)
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: org.apache.camel.ResolveEndpointFailedException: Failed to
resolve endpoint:
direct://end?pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true&pollingConsumerQueueSize=1000
due to: Error binding property (pollingConsumerBlockTimeout=0) with name:
pollingConsumerBlockTimeout on bean:
direct://end?pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true&pollingConsumerQueueSize=1000
with value: 0
at
org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:876)
at
org.apache.camel.impl.engine.AbstractCamelContext.getEndpoint(AbstractCamelContext.java:766)
at
org.apache.camel.kafkaconnector.utils.CamelMainSupport.getEndpoint(CamelMainSupport.java:142)
at
org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:96)
... 8 more
Caused by: org.apache.camel.PropertyBindingException: Error binding property
(pollingConsumerBlockTimeout=0) with name: pollingConsumerBlockTimeout on bean:
direct://end?pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true&pollingConsumerQueueSize=1000
with value: 0
at
org.apache.camel.support.PropertyBindingSupport.bindProperty(PropertyBindingSupport.java:630)
at
org.apache.camel.support.PropertyBindingSupport.lambda$doBindProperties$2(PropertyBindingSupport.java:608)
at
java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
at
java.util.stream.SortedOps$SizedRefSortingSink.end(SortedOps.java:357)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:483)
at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
at
java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
at
java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at
java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
at
org.apache.camel.support.PropertyBindingSupport.doBindProperties(PropertyBindingSupport.java:573)
at
org.apache.camel.support.PropertyBindingSupport.access$000(PropertyBindingSupport.java:71)
at
org.apache.camel.support.PropertyBindingSupport$Builder.bind(PropertyBindingSupport.java:258)
at
org.apache.camel.support.DefaultEndpoint.setProperties(DefaultEndpoint.java:433)
at
org.apache.camel.support.DefaultEndpoint.configureProperties(DefaultEndpoint.java:401)
at
org.apache.camel.support.DefaultComponent.setProperties(DefaultComponent.java:453)
at
org.apache.camel.component.direct.DirectComponent.createEndpoint(DirectComponent.java:51)
at
org.apache.camel.support.DefaultComponent.createEndpoint(DefaultComponent.java:237)
at
org.apache.camel.impl.engine.AbstractCamelContext.doGetEndpoint(AbstractCamelContext.java:844)
... 11 more
Caused by: java.lang.IllegalArgumentException: Could not find a suitable
setter for property: pollingConsumerBlockTimeout as there isn't a setter method
with same type: java.lang.String nor type conversion possible: No type
converter available to convert from type: java.lang.String to the required
type: long with value 0
at
org.apache.camel.support.IntrospectionSupport.setProperty(IntrospectionSupport.java:779)
at
org.apache.camel.impl.engine.DefaultBeanIntrospection.setProperty(DefaultBeanIntrospection.java:195)
at
org.apache.camel.support.PropertyBindingSupport.setProperty(PropertyBindingSupport.java:734)
at
org.apache.camel.support.PropertyBindingSupport.bindProperty(PropertyBindingSupport.java:627)
... 29 more
```
Thanks for taking a glance!
----------------------------------------------------------------
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:
[email protected]
