# lensesio/stream-reactor

A collection of Kafka Connect sinks and sources maintained by Lenses.io.

Repository: https://github.com/lensesio/stream-reactor
Canonical: https://ross.abutalabs.com/products/stream-reactor
Homepage: https://lenses.io
Language: Scala
License: Apache-2.0
License Family: permissive
Topics: kafka, kafka-connect, connector, cassandra, elasticsearch, influxdb, mqtt, jms, mongodb, cosmosdb, awss3, azure-datalake, eventhubs, http, s3, gcp, pubsub
Last push: 2026-08-26T12:08:49+00:00

## Health v2 (maintenance only)
Score: 95/100 (v2, computed 2026-09-03T02:39:23.370411+00:00)
- activity 99, release rhythm 87, longevity 100
- inputs: {"age_days": 3881, "days_push": 7, "days_rel": 7, "gap_med": 6, "n_releases_24m": 68}
- flags: none
- formula: round(0.45*activity + 0.35*rhythm + 0.20*longevity); archived -> min(score, 10)

## Adoption (not part of the score)
Stars 1068, forks 375 (observed 2026-08-28T04:03:27.487463+00:00)

## What it is
Stream Reactor is a collection of Apache 2.0 licensed Kafka Connect sinks and sources maintained by Lenses.io since 2016. It provides connectors for systems like Cassandra, Elasticsearch, InfluxDB, MongoDB, MQTT, JMS, CosmosDB, AWS S3, Azure Data Lake, Event Hubs, HTTP, and GCP Pub/Sub.

## Use cases
- stream data from kafka into cassandra
- sink kafka topics to elasticsearch or opensearch
- write kafka records to mongodb
- connect kafka to aws s3 or azure data lake
- bridge mqtt devices with kafka
- publish kafka messages to gcp pub/sub
- move data between kafka and legacy systems via jms

## When to choose
- you need Apache-2.0 licensed Kafka Connect connectors for a wide range of sinks and sources
- you want a mature, community-maintained connector suite with commercial support options
- you need connectors for niche systems like MQTT, JMS, InfluxDB, or CosmosDB

## When to avoid
- you rely on deprecated connectors such as Elasticsearch 6, Kudu, Hazelcast, HBase, Hive, or Pulsar
- you need a single-purpose connector with deeper vendor-specific features than this collection offers
- you are not using Kafka Connect as your integration framework

## Facets
- artifact type: library
- maturity: active
- function: streaming, etl, message-queue, database-driver
- domain: big-data, databases, developer-tools
- platform: jvm, self-hosted
- tags: kafka-connect, kafka-connectors, stream-reactor, sinks, sources, data-integration, apache-kafka, data-engineering, messaging, docker

## Member repositories
- lensesio/stream-reactor (main) score 95

## Provenance
- Observed fields: from GitHub, fetched 2026-08-28T04:03:27.487463+00:00.
- Health v2: computed from the inputs above; adoption is never an input.
- Inferred fields (summary, facets, guidance): AI-extracted, prompt v1, taxonomy v1, on 2026-08-30T06:54:43.765023+00:00, confidence not recorded.
  - readme: https://github.com/lensesio/stream-reactor (fetched 2026-08-28T04:03:27.487463+00:00, sha 6654e4bc5047)
  - homepage: https://lenses.io (fetched 2026-08-29T12:56:51.975575+00:00, sha ad0c832ad516)
  - site_page: https://lenses.io/company/about-us (fetched 2026-08-29T12:56:51.988537+00:00, sha 615c99c37dbe)
  - site_page: https://docs.lenses.io (fetched 2026-08-29T12:56:51.990253+00:00, sha 042cab62ae01)
  - site_page: https://lenses.io/community-edition (fetched 2026-08-29T12:56:51.985037+00:00, sha 701e77bff5f5)
  - site_page: https://lenses.io/product/pricing (fetched 2026-08-29T12:56:51.986878+00:00, sha 018f8b16d477)
- Data as of 2026-08-30T08:39:29.467469+00:00.