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
  • API
  • Support
  • Releases
  1. Connectors
  2. Sinks
  • Setup
    • Install
    • Dockers
    • Docker compose
    • Helm charts
    • Bring your own connector
    • Kafka Connect Examples
  • Sources
    • AWS S3
    • Cassandra
    • FTP
    • Hive
    • JMS
    • MQTT
    • Pulsar
    • Source record converters
  • Sinks
    • Azure CosmosDB
    • AWS S3
    • Cassandra
    • Elastic
    • Hazelcast
    • HBase
    • Hive
    • InfluxDB
    • JMS
    • Kudu
    • MongoDB
    • MQTT
    • Pulsar
    • 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
  • Setup
    • Install
    • Dockers
    • Docker compose
    • Helm charts
    • Bring your own connector
    • Kafka Connect Examples
  • Sources
    • AWS S3
    • Cassandra
    • FTP
    • Hive
    • JMS
    • MQTT
    • Pulsar
    • Source record converters
  • Sinks
    • Azure CosmosDB
    • AWS S3
    • Cassandra
    • Elastic
    • Hazelcast
    • HBase
    • Hive
    • InfluxDB
    • JMS
    • Kudu
    • MongoDB
    • MQTT
    • Pulsar
    • 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
  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

Cassandra

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

Elastic

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

Hazelcast

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

HBase

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

Hive

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

InfluxDB

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

JMS

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

Kudu

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

MongoDB

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

MQTT

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

Pulsar

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

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.