How to Create a Sink Connector in ksqlDB

This is an example of creating a sink connector that publishes to Slack using Apache Camel connectors:

CREATE SINK CONNECTOR slack_test WITH (
  'topics' = 'tweets',
  'connector.class' = 'org.apache.camel.kafkaconnector.slacksink.CamelSlacksinkSinkConnector',
  'camel.kamelet.slack-sink.webhookUrl' = 'https://hooks.slack.com/services/XXXXXX/XXXXXX/XXXXXXXXXXX',
  'camel.kamelet.slack-sink.channel' = 'camel-records'
);

Was this article helpful?