[GitHub] [camel-kafka-connector] iamrsaravana edited a comment on issue #817: Reading data from AMQP protocal using Strimzi kafka connector

[GitBox <gi...@apache.org>]

iamrsaravana edited a comment 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.connectionFactory**
   
   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:
users@infra.apache.org