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}