iamrsaravana commented on issue #817: URL: https://github.com/apache/camel-kafka-connector/issues/817#issuecomment-751598608
Thanks for your reply, I Gave direct IP address like below: **camel.component.amqp.connectionFactory: org.apache.qpid.jms.JmsConnectionFactory camel.component.amqp.connectionFactory.remoteURI: amqp://10.106.88.243:15671** I referred the below link for configuration properties, but I am not finding **"camel.component.amqp.connectionFactory.remoteURI"**: https://camel.apache.org/camel-kafka-connector/latest/connectors/camel-amqp-kafka-source-connector.html I am getting below error messages now: org.apache.kafka.connect.errors.ConnectException: Failed to create and start Camel context at org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:144) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) 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) Caused by: java.lang.IllegalArgumentException: Cannot find getter method: connectionFactory on bean: class org.apache.camel.component.amqp.AMQPComponent when binding property: connectionFactory.remoteURI at org.apache.camel.support.PropertyBindingSupport.doBuildPropertyOgnlPath(PropertyBindingSupport.java:282) at org.apache.camel.support.PropertyBindingSupport.doBindProperties(PropertyBindingSupport.java:210) at org.apache.camel.support.PropertyBindingSupport.access$100(PropertyBindingSupport.java:88) at org.apache.camel.support.PropertyBindingSupport$Builder.bind(PropertyBindingSupport.java:1785) at org.apache.camel.main.MainHelper.setPropertiesOnTarget(MainHelper.java:163) at org.apache.camel.main.BaseMainSupport.autoConfigurationFromProperties(BaseMainSupport.java:1133) at org.apache.camel.main.BaseMainSupport.autoconfigure(BaseMainSupport.java:424) at org.apache.camel.main.BaseMainSupport.postProcessCamelContext(BaseMainSupport.java:472) at org.apache.camel.main.SimpleMain.doInit(SimpleMain.java:32) at org.apache.camel.support.service.BaseService.init(BaseService.java:83) at org.apache.camel.support.service.BaseService.start(BaseService.java:111) at org.apache.camel.kafkaconnector.CamelSourceTask.start(CamelSourceTask.java:141) Anybody gives a suggestion how to pass source AMQP IP address in the configuration: ---------------------------------------------------------------- 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]
