This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch oscerd-patch-amqp
in repository
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git
commit 2e3070010dac37c604578b56658340d15d889960
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Mon Dec 7 07:19:29 2020 +0100
Camel-Amqp-Kafka-Connector source example: Fixed options
---
amqp/config/CamelAmqpSourceConnector.properties | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/amqp/config/CamelAmqpSourceConnector.properties
b/amqp/config/CamelAmqpSourceConnector.properties
index 2ed871b..fe9ca91 100644
--- a/amqp/config/CamelAmqpSourceConnector.properties
+++ b/amqp/config/CamelAmqpSourceConnector.properties
@@ -20,8 +20,8 @@ topics=mytopic
tasks.max=1
connector.class=org.apache.camel.kafkaconnector.amqp.CamelAmqpSourceConnector
-camel.sink.path.destinationType=queue
-camel.sink.path.destinationName=test-queue
+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
