This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository
https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git
The following commit(s) were added to refs/heads/master by this push:
new 2df46bc Camel-Amqp-Kafka-Connector source example: Fixed options
2df46bc is described below
commit 2df46bc94d2441d4ce9de0d869103e6055f9333c
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
