Skip to content

Add CamelAMQP source and sink example properties #264

Closed
@rgannu

Description

@rgannu

I was struggling for a day to determine how to transfer the data from kafka to amqp 1.0 broker end point using the camel-amqp-kafka-connector. At the end I was able to do that with the attached sink configuration.
Could you please add this as part of the examples directory ?
Also, please add the corresponding the AMQP source configuration.

examples/CamelAmqpSinkConnector.properties

name=CamelAmqpSinkConnector
topics=mytopic
tasks.max=1
connector.class=org.apache.camel.kafkaconnector.amqp.CamelAmqpSinkConnector

camel.sink.path.destinationType=queue
camel.sink.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

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions