lensesio/stream-reactor
A collection of Kafka Connect sinks and sources maintained by Lenses.io. observed · 2026-08-28
Health v2 · maintenance only
95/100
- Activity 99
- Release rhythm 87
- Longevity 100
How is this computed?
round(0.45*activity + 0.35*rhythm + 0.20*longevity); archived -> min(score, 10) — computed 2026-09-03. Adoption (stars, forks) is never an input.
- gap_med: 6
- age_days: 3881
- days_rel: 7
- days_push: 7
- n_releases_24m: 68
Adoption not part of the score
1068 stars · 375 forks observed · 2026-08-28
What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded
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
library · maturity active
streaming etl message-queue database-driver big-data databases developer-tools jvm self-hosted kafka-connect kafka-connectors stream-reactor sinks sources data-integration apache-kafka data-engineering messaging docker
6 sources
- readme: https://github.com/lensesio/stream-reactor · fetched 2026-08-28 · 6654e4bc5047
- homepage: https://lenses.io · fetched 2026-08-29 · ad0c832ad516
- site_page: https://lenses.io/company/about-us · fetched 2026-08-29 · 615c99c37dbe
- site_page: https://docs.lenses.io · fetched 2026-08-29 · 042cab62ae01
- site_page: https://lenses.io/community-edition · fetched 2026-08-29 · 701e77bff5f5
- site_page: https://lenses.io/product/pricing · fetched 2026-08-29 · 018f8b16d477
Member repositories
| Repository | Role | Health v2 |
|---|---|---|
| lensesio/stream-reactor | main | 95 |
For agents
markdown · JSON · MCP: product_card(name="lensesio/stream-reactor")
Data as of 2026-08-30T08:39:29.467469+00:00 · Report a problem