This is not the latest version. View the latest documentation
Kafka Connect Hub for sink connectors | Lenses.io Documentation
Lenses.io Help Center
Lenses.io Help Center
  • Documentation
5.5 (Latest) 5.4 5.3 5.2 5.1 5.0 4.3 4.2 4.1 4.0 3.2 3.1 3.0 2.3 2.2 2.1 2.0 1.1 1.0
  • Installation
    Overview Getting started Configuration Moving to production Configuration reference
  • Guides
    Overview Admin Data observibility Compliance Self service & governance Data applications & integration CLI
  • Lenses SQL
    Overview SQL Studio Streaming SQL SQL tutorials Expressions Functions Custom functions Deserializers Supported data formats
  • Connectors
    Overview Setup Sources Sinks Connect CLI Kafka Connect Secrets Release notes
  • APIs
  • Support
  • Releases
  1. Connectors
  2. Sinks
  • Setup
    • Install
    • Dockers
    • Docker compose
    • Helm charts
    • Bring your own connector
    • Kafka Connect Examples
  • Sources
    • AWS S3
    • GCP Storage
    • Cassandra
    • FTP
    • JMS
    • EventHubs
    • MQTT
    • Cloud Sources Examples
      • AWS S3 Source Connector Examples
      • AWS S3 Source Connector Time-Based Partitioning Examples
      • GCP Storage Source Connector Examples
      • GCP Storage Source Connector Time-Based Partitioning Examples
    • Source record converters
  • Sinks
    • Azure CosmosDB
    • AWS S3
    • Azure Datalake
    • Cassandra
    • GCP Storage
    • HTTP
    • Elastic
    • InfluxDB
    • JMS
    • MongoDB
    • MQTT
    • Redis
    • Payload support
    • Error policies
  • Connect CLI
  • Kafka Connect Secrets
    • AWS Secret Manager
    • Azure Keyvault
    • Hashicorp Vault
    • Environment
    • AES-256 Decryption
    • Other applications
  • Release notes
    • Secret provider
    • Package Name Changes
  • Package Name Warning
  • Setup
    • Install
    • Dockers
    • Docker compose
    • Helm charts
    • Bring your own connector
    • Kafka Connect Examples
  • Sources
    • AWS S3
    • GCP Storage
    • Cassandra
    • FTP
    • JMS
    • EventHubs
    • MQTT
    • Cloud Sources Examples
      • AWS S3 Source Connector Examples
      • AWS S3 Source Connector Time-Based Partitioning Examples
      • GCP Storage Source Connector Examples
      • GCP Storage Source Connector Time-Based Partitioning Examples
    • Source record converters
  • Sinks
    • Azure CosmosDB
    • AWS S3
    • Azure Datalake
    • Cassandra
    • GCP Storage
    • HTTP
    • Elastic
    • InfluxDB
    • JMS
    • MongoDB
    • MQTT
    • Redis
    • Payload support
    • Error policies
  • Connect CLI
  • Kafka Connect Secrets
    • AWS Secret Manager
    • Azure Keyvault
    • Hashicorp Vault
    • Environment
    • AES-256 Decryption
    • Other applications
  • Release notes
    • Secret provider
    • Package Name Changes
  • Package Name Warning
  1. Connectors
  2. Sinks

Sinks


Stream Reactor sink connectors support KCQL.

Tip
You can specify multiple KCQL statements separated by ; to have a the connector sink multiple topics.

Azure CosmosDB

A Kafka Connect sink connector for writing records from Kafka to Azure CosmosDB using the SQL API.

AWS S3

A Kafka Connect sink connector for writing records from Kafka to AWS S3 buckets

Azure Datalake

A Kafka Connect sink connector for writing records from Kafka to Azure Datalake buckets

Cassandra

A Kafka Connect sink connector for writing records from Kafka to Cassandra.

GCP Storage

A Kafka Connect sink connector for writing records from Kafka to GCP Storage buckets

HTTP

A Kafka Connect sink connector for writing records from Kafka to HTTP endpoints.

Elastic

A set of Kafka Connect sink connectors for writing records from Kafka to Elastic.

InfluxDB

Kafka Connect sink connector for writing data from Kafka to InfluxDB.

JMS

Kafka Connect sink connector for writing data from Kafka to JMS.

MongoDB

Kafka Connect sink connector for writing data from Kafka to MongoDB.

MQTT

Kafka Connect sink connector for writing data from Kafka to MQTT.

Redis

Kafka Connect sink connector for writing data from Kafka to Redis.

Payload support

Error policies

Feedback

Was this page helpful?

Awesome, thank you!

Sorry to hear that. Please tell us how we can improve!

2022 © Lenses.io Ltd. Policy Terms Cookies

Apache, Apache Kafka, Kafka, and associated open source project names are trademarks of the Apache Software Foundation.