Slack

Slack sink connector

Support Those Engines

Spark
Flink
SeaTunnel Zeta

Key features

• exactly-once
• cdc

Description

Used to send SeaTunnel rows to a Slack channel. Both streaming and batch jobs are supported.

The connector sends the row values as one comma-separated Slack message. For example, a row with values huan and 17 is sent as huan,17.

Data Type Mapping

All field values are converted to strings before they are sent to Slack.

Options

Name	Type	Required	Default	Description
webhooks_url	String	Yes	-	Slack webhook URL.
oauth_token	String	Yes	-	Slack OAuth token used to list channels and post messages.
slack_channel	String	Yes	-	Slack channel name for data writes.
common-options		no	-	Sink plugin common parameters, please refer to Sink Common Options for details

Task Example

Simple

sink {
 Slack {
  webhooks_url = "https://hooks.slack.com/services/xxxxxxxxxxxx/xxxxxxxxxxxx/xxxxxxxxxxxxxxxx"
  oauth_token = "xoxp-xxxxxxxxxx-xxxxxxxx-xxxxxxxxx-xxxxxxxxxxx"
  slack_channel = "seatunnel-alerts"
 }
}

Changelog

Change Log

Change	Commit	Version
[improve] Slack connector options (#8738)	https://github.com/apache/seatunnel/commit/eb706743fe	2.3.10
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)	https://github.com/apache/seatunnel/commit/6b7c53d03c	2.3.9
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755)	https://github.com/apache/seatunnel/commit/8de7408100	2.3.4
[Improve][build] Give the maven module a human readable name (#4114)	https://github.com/apache/seatunnel/commit/d7cd601051	2.3.1
[Improve][Project] Code format with spotless plugin. (#4101)	https://github.com/apache/seatunnel/commit/a2ab166561	2.3.1
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)	https://github.com/apache/seatunnel/commit/226dc6a119	2.3.0
[Feature][Connector-V2][Slack] Add Slack sink connector (#3226)	https://github.com/apache/seatunnel/commit/7a836f2d44	2.3.0