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. Sources
  • Setup
    • Install
    • Dockers
    • Docker compose
    • Helm charts
    • Bring your own connector
    • Kafka Connect Examples
  • Sources
    • AWS S3
    • GCP Pub/Sub
    • GCP Storage
    • Cassandra
    • FTP
    • JMS
    • EventHubs
    • MQTT
    • ServiceBus
    • 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
    • Service Bus
    • 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 Pub/Sub
    • GCP Storage
    • Cassandra
    • FTP
    • JMS
    • EventHubs
    • MQTT
    • ServiceBus
    • 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
    • Service Bus
    • 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. 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. See article about specific Connectors to know the details.

AWS S3

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

GCP Pub/Sub

A Kafka Connect source connector for writing records from GCP Pub/Sub topics abd queues to Kafka

GCP Storage

A Kafka Connect source connector for writing records from GCP Storage 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

JMS

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

EventHubs

A Kafka Connect source connector to read events from Azure Event Hubs and push them to Kafka

MQTT

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

ServiceBus

A Kafka Connect source connector to read events from Azure Service Bus and push them to Kafka

Cloud Sources Examples

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.