iamrsaravana commented on issue #817: URL: https://github.com/apache/camel-kafka-connector/issues/817#issuecomment-751365170
I was referring the below link and gave my inputs https://github.com/apache/camel-kafka-connector/blob/master/examples/CamelAmqpSourceConnector.properties Values are in this file as mentioned it below: name=CamelAmqpSourceConnector topics=mytopic tasks.max=1 connector.class=org.apache.camel.kafkaconnector.amqp.CamelAmqpSourceConnector camel.source.path.destinationType=queue camel.source.path.destinationName=test-queue camel.component.amqp.includeAmqpAnnotations=true **camel.component.amqp.connectionFactory=#class:org.apache.qpid.jms.JmsConnectionFactory camel.component.amqp.connectionFactory.remoteURI=amqp://localhost:5672** camel.component.amqp.username=admin camel.component.amqp.password=admin camel.component.amqp.testConnectionOnStartup=true I am using the below configurations. Could you suggest me what is the correct value for this property? **camel.component.amqp.connectionFactor** apiVersion: kafka.strimzi.io/v1alpha1 kind: KafkaConnector metadata: name: camelamqpsourceconnector labels: strimzi.io/cluster: my-connect-cluster-new spec: class: org.apache.camel.kafkaconnector.amqp.CamelAmqpSourceConnector tasksMax: 1 config: camel.component.amqp.includeAmqpAnnotations: true **camel.component.amqp.connectionFactory: org.apache.qpid.jms.JmsConnectionFactory camel.component.amqp.connectionFactory.remoteURI: amqp://$( kubectl get service eclipse-hono-dispatch-router-ext --output="jsonpath={.spec.clusterIP}" -n hono):15671** camel.component.amqp.username: consumer@HONO camel.component.amqp.password: verysecret camel.component.amqp.testConnectionOnStartup: true camel.source.kafka.topic: mytopic camel.source.path.destinationType: queue camel.source.path.destinationName: test-queue ---------------------------------------------------------------- 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]
