[GitHub] [camel-kafka-connector] oscerd commented on issue #817: Reading data from AMQP protocal using Strimzi kafka connector

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

oscerd commented on issue #817:
URL: https://github.com/apache/camel-kafka-connector/issues/817#issuecomment-751213044


   What do you see in log?
   
   Il ven 25 dic 2020, 08:26 iamrsaravana <no...@github.com> ha
   scritto:
   
   > I am planning to pull the data from Hono using Strimzi kafka(Version
   > 0.20.0) connector (Camel AMQP source connector). I have followed the below
   > steps to read data from Hono.
   >
   > I downloaded Camel-amqp-kafka-connector, JMS Jar files from below link:
   >
   >
   > https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-amqp-kafka-connector/0.7.0/camel-amqp-kafka-connector-0.7.0-package.tar.gz
   >
   > https://downloads.apache.org/qpid/jms/0.51.0/apache-qpid-jms-0.51.0-bin.tar.gz
   >
   > After downloaded the above tar and unzipped and created docker image file
   > using below command
   >
   > cat <Dockerfile
   > FROM strimzi/kafka:0.20.1-kafka-2.6.0
   > USER root:root
   > RUN mkdir -p /opt/kafka/plugins/camel
   > COPY ./camel-activemq-kafka-connector/* /opt/kafka/plugins/camel/
   > USER 1001
   > EOF
   >
   > Docker build -f ./Dockerfile -t localhost:5000/my-connector-amqp_new .
   > docker push localhost:5000/my-connector-amqp_new
   >
   > using below command i have created kafkaConnect( here used my local image
   > created above)
   >
   > apiVersion: kafka.strimzi.io/v1beta1
   > kind: KafkaConnect
   > metadata:
   > name: my-connect-cluster
   > annotations:
   > strimzi.io/use-connector-resources: "true"
   > spec:
   > image: 10.128.0.6:5000/my-connector-amqp_new
   > replicas: 1
   > bootstrapServers: my-cluster-kafka-bootstrap:9092
   > config:
   > group.id: connect-cluster
   > offset.storage.topic: connect-cluster-offsets
   > config.storage.topic: connect-cluster-configs
   > status.storage.topic: connect-cluster-status
   > config.storage.replication.factor: 1
   > offset.storage.replication.factor: 1
   > status.storage.replication.factor: 1
   >
   > using below command to pull the data from hono message queue:
   >
   > apiVersion: kafka.strimzi.io/v1alpha1
   > kind: KafkaConnector
   > metadata:
   > name: camelamqpsourceconnector
   > labels:
   > strimzi.io/cluster: my-connect-cluster
   > spec:
   > class: org.apache.camel.kafkaconnector.amqp.CamelAmqpSourceConnector
   > tasksMax: 1
   > config:
   > camel.component.amqp.includeAmqpAnnotations: true
   > camel.component.amqp.connectionFactory.class:
   > org.apache.qpid.jms.JmsConnectionFactory
   > camel.component.amqp.connectionFactory.remoteURI: $( kubectl get service
   > eclipse-hono-dispatch-router-ext --output="jsonpath={.spec.clusterIP}" -n
   > hono):15672
   > 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
   >
   > i am not getting any data in my above kafka topics (mytopic)
   >
   > Could you check is there any i need to modify to get the data in my kafka
   > topics. I have searched various forum but i could not get any clear
   > direction.
   >
   > —
   > You are receiving this because you are subscribed to this thread.
   > Reply to this email directly, view it on GitHub
   > <https://github.com/apache/camel-kafka-connector/issues/817>, or
   > unsubscribe
   > <https://github.com/notifications/unsubscribe-auth/ABG6XV7POLF3RW5GFJKG4ZDSWQ5BTANCNFSM4VI5DDCQ>
   > .
   >
   


----------------------------------------------------------------
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