You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/08/05 17:15:51 UTC
[camel-kafka-connector-examples] 01/01: Fixed Nats Sink connector
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch fix-nats-sink
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git
commit 192060277829b5efd9b18c2a563a78bab04f9aca
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Aug 5 19:15:23 2020 +0200
Fixed Nats Sink connector
---
nats/nats-sink/README.adoc | 2 +-
nats/nats-sink/config/CamelNatsSinkConnector.properties | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/nats/nats-sink/README.adoc b/nats/nats-sink/README.adoc
index 43e07ae..e4163e6 100644
--- a/nats/nats-sink/README.adoc
+++ b/nats/nats-sink/README.adoc
@@ -50,7 +50,7 @@ Now it's time to setup the connectors
Open the NATS configuration file
```
-name=CamelNatsSourceConnector
+name=CamelNatsSinkConnector
connector.class=org.apache.camel.kafkaconnector.nats.CamelNatsSinkConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
diff --git a/nats/nats-sink/config/CamelNatsSinkConnector.properties b/nats/nats-sink/config/CamelNatsSinkConnector.properties
index dd13df3..c3e7e61 100644
--- a/nats/nats-sink/config/CamelNatsSinkConnector.properties
+++ b/nats/nats-sink/config/CamelNatsSinkConnector.properties
@@ -15,7 +15,7 @@
# limitations under the License.
#
-name=CamelNatsSourceConnector
+name=CamelNatsSinkConnector
connector.class=org.apache.camel.kafkaconnector.nats.CamelNatsSinkConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter