iamrsaravana commented on issue #817:
URL:
https://github.com/apache/camel-kafka-connector/issues/817#issuecomment-751646678
I gave input in yaml file as you mentioned it below:
camel.component.amqp.connectionFactory:
#class:org.apache.qpid.jms.JmsConnectionFactory
camel.component.amqp.connectionFactory.remoteURI: amqp://10.106.88.243:15671
Still i am getting below error message:
Spec:
Class: org.apache.camel.kafkaconnector.amqp.CamelAmqpSourceConnector
Config:
camel.component.amqp.connectionFactory: <nil>
camel.component.amqp.connectionFactory.remoteURI:
amqp://10.106.88.243:15671
camel.component.amqp.includeAmqpAnnotations: true
camel.component.amqp.password: verysecret
camel.component.amqp.testConnectionOnStartup: true
camel.component.amqp.username: consumer@HONO
camel.source.kafka.topic: mytopic
camel.source.path.destinationName: test-queue
camel.source.path.destinationType: queue
Tasks Max: 1
Status:
Conditions:
Last Transition Time: 2020-12-28T09:16:21.630894Z
Status: True
Type: Ready
Connector Status:
Connector:
State: FAILED
Trace: java.lang.ClassCastException: Non-string value found in
original settings for key **camel.component.amqp.connectionFactory: null**
at
org.apache.kafka.common.config.AbstractConfig.originalsStrings(AbstractConfig.java:241)
at
org.apache.kafka.connect.runtime.WorkerConnector.<init>(WorkerConnector.java:88)
at
org.apache.kafka.connect.runtime.Worker.startConnector(Worker.java:282)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder.startConnector(DistributedHerder.java:1321)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$1400(DistributedHerder.java:127)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:1329)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:1325)
at
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
worker_id: 10.244.1.137:8083
Name: camelamqpsourceconnector
Tasks:
Type: source
Observed Generation: 1
Tasks Max: 1
Events: <none>
----------------------------------------------------------------
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]
