iamrsaravana opened a new issue #817: URL: https://github.com/apache/camel-kafka-connector/issues/817
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 <<EOF >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. ---------------------------------------------------------------- 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]
