Kafka Connect Sink for posting to slack
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
.circleci
gradle/wrapper
src
terraform
.gitignore
README.md
build.gradle
gradlew
gradlew.bat
kafka-connect-slack.iml
settings.gradle

README.md

kafka-connect-slack

A kafka-connect sink connector, for formatting, and sending messages to Slack

CircleCI

🔌 Installation

Download the latest jar and place it in your kafka-connect plugins folder.

🛠 Configuration

resource "kafka-connect_connector" "slack_sink" {
  name = "slack_sink"

  config = {
    "name"             = "slack_sink"
    "connector.class"  = "net.mongey.kafka.connect.SlackSinkConnector"
    "topics"           = "paid-orders"
    "slack.token"      = "${var.slack_token}"
    "slack.channel"    = "shipping-requests"
    "message.template" = "${customer.firstname} created a new order"
  }
}
  • slack.token is the slack token for the connector to use.
  • slack.channel defines what channel to send the message into. (Optional)
  • slack.username defines the user to send the message to. (Optional)
  • message.template defines the template to use for the message.

📝 message.template

Interpolate fields from the message using ${field_name}. Nested fields are accessible using a . e.g. ${customer.address.city}