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/11/04 06:43:36 UTC
[camel-kafka-connector-examples] 02/02: Slack Source: Use Slack
built-in transform, fix the ref in configuration files
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
commit 508cd9cd071733127866b889ecf74c1a97028a2d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Nov 4 07:41:00 2020 +0100
Slack Source: Use Slack built-in transform, fix the ref in configuration files
---
slack/slack-source/config/CamelSlackSourceConnector.properties | 2 +-
slack/slack-source/config/openshift/slack-source.yaml | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/slack/slack-source/config/CamelSlackSourceConnector.properties b/slack/slack-source/config/CamelSlackSourceConnector.properties
index f1b7073..9eb473b 100644
--- a/slack/slack-source/config/CamelSlackSourceConnector.properties
+++ b/slack/slack-source/config/CamelSlackSourceConnector.properties
@@ -19,7 +19,7 @@ name=CamelSlackSourceConnector
connector.class=org.apache.camel.kafkaconnector.slack.CamelSlackSourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
transforms=SlackTransformer
-transforms.SlackTransformer.type=org.apache.camel.kafkaconnector.SlackTransformer
+transforms.SlackTransformer.type=org.apache.camel.kafkaconnector.slack.transformers.SlackTransforms
topics=mytopic
diff --git a/slack/slack-source/config/openshift/slack-source.yaml b/slack/slack-source/config/openshift/slack-source.yaml
index 15b6e6b..c5f58c5 100644
--- a/slack/slack-source/config/openshift/slack-source.yaml
+++ b/slack/slack-source/config/openshift/slack-source.yaml
@@ -11,7 +11,7 @@ spec:
config:
key.converter: org.apache.kafka.connect.storage.StringConverter
transforms: SlackTransformer
- transforms.SlackTransformer.type: org.apache.camel.kafkaconnector.SlackTransformer
+ transforms.SlackTransformer.type: org.apache.camel.kafkaconnector.slack.transformers.SlackTransforms
topics: slack-topic
camel.source.path.channel: general
camel.source.endpoint.token: ${file:/opt/kafka/external-configuration/slack-token/slack-token.properties:token}