This is not the latest version. View the latest documentation
Kafka Connect Hub for source 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. Sources
  • 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. Sources

Sources


Stream Reactor sources connectors support KCQL.

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

AWS S3

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

Cassandra

Kafka Connect Cassandra is a Source Connector for reading data from Cassandra and writing to Kafka

FTP

Kafka Connect source connector that monitors files on an FTP server and feeds changes into Kafka

Hive

Kafka Connect source connector for reading data from Hive and writing to Kafka

JMS

A Kafka Connect JMS source connector to subscribe to messages on JMS queues and topics and write them to a Kafka topic

MQTT

A Kafka Connect source connector to read events from MQTT and push them to Kafka

Pulsar

A Kafka Connect source connector to write events from Apache Pulsar to Apache Kafka

Source record converters

Convert your source system records to Connect Structs

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.