Events in.
Nothing lost.
Glue between your services, internal or external, with a buffer for when one goes down. Schema AI runs on our own hardware in the Nordics.
↓ Incoming event
{
"meter_id": "EM-2231-B",
"building": "Søndervang School",
"kind": "heat",
"kwh": 1284.6,
"flow_temp": 58.4,
"ts": "2026-10-31T07:45:00Z"
}
"meter_id": "EM-2231-B",
"building": "Søndervang School",
"kind": "heat",
"kwh": 1284.6,
"flow_temp": 58.4,
"ts": "2026-10-31T07:45:00Z"
}
◇ Schema detected
meter_id
String
LowCard
building
String
LowCard
kind
String
LowCard
kwh
Float32
Gorilla
flow_temp
Float32
Gorilla
ts
DateTime64
DoubleDelta
→ Forwarded
HTTPS
energy-platform.eu/ingest
{ meter_id, kind, kwh, ts }
pinned to v1, 4 fields
HTTPS
utility-portal.eu/readings
{ meter: "EM-2231-B", value: 1284.6 }
mapped to the utility’s format
MQTT
alarms/heat/flow_temp
{ building, flow_temp }
transform, only above 55 °C
✓ 1 reading stored and forwarded to 3 destinations (38 ms)
↓ Incoming event
{
"repository": "acme/api",
"ref": "refs/heads/main",
"pusher": "maria",
"commits": 3,
"forced": false,
"pushed_at": "2026-10-31T09:14:05Z"
}
"repository": "acme/api",
"ref": "refs/heads/main",
"pusher": "maria",
"commits": 3,
"forced": false,
"pushed_at": "2026-10-31T09:14:05Z"
}
◇ Schema detected
repository
String
LowCard
ref
String
LowCard
pusher
String
LowCard
commits
Int32
Delta
forced
Bool
ZSTD
pushed_at
DateTime64
DoubleDelta
→ Forwarded
HTTPS
ci.acme.dev/deploy
{ repository, ref, commits }
transform, main branch only
HTTPS
hooks.slack.com
{ text: "maria pushed 3 commits to acme/api" }
mapped to a message
HTTPS
analytics.acme.io
{ repository, ref, pusher, commits, forced, pushed_at }
pass-through, all fields
✓ 1 webhook stored and delivered to 3 consumers (41 ms)
↓ Incoming event
{
"order_id": "ord_51920",
"customer": "c_1182",
"total": 84.5,
"currency": "EUR",
"items": 3,
"created_at": "2026-10-31T11:20:12Z"
}
"order_id": "ord_51920",
"customer": "c_1182",
"total": 84.5,
"currency": "EUR",
"items": 3,
"created_at": "2026-10-31T11:20:12Z"
}
◇ Schema detected
order_id
String
LowCard
customer
String
LowCard
total
Float32
Gorilla
currency
String
LowCard
items
Int32
Delta
created_at
DateTime64
DoubleDelta
→ Forwarded
HTTPS
warehouse.acme.io
Online
{ order_id, customer, total, created_at }
back online, replayed in order
1,284 orders replayed
HTTPS
fulfilment.acme.io
{ order_id, items, created_at }
delivered as usual
WebSocket
ops dashboard
{ order_id, total, currency }
mapped, 3 fields
✓ warehouse.acme.io is back: 1,284 stored orders replayed in order
↓ Incoming event
{
"serial": "HP-80412",
"model": "AirFlow 9",
"cop": 3.8,
"outdoor_temp": -2.5,
"compressor_hz": 54,
"ts": "2026-10-31T06:30:00Z"
}
"serial": "HP-80412",
"model": "AirFlow 9",
"cop": 3.8,
"outdoor_temp": -2.5,
"compressor_hz": 54,
"ts": "2026-10-31T06:30:00Z"
}
◇ Schema detected
serial
String
LowCard
model
String
LowCard
cop
Float32
Gorilla
outdoor_temp
Float32
Gorilla
compressor_hz
Int32
Delta
ts
DateTime64
DoubleDelta
→ Forwarded
HTTPS
app.heatpump-co.eu
{ cop, outdoor_temp, ts }
the owner’s own data
HTTPS
service.partner.dk
{ serial, model, compressor_hz, ts }
shared on request, history included
12 months replayed
MQTT
fleet/analytics
{ serial, model, cop, outdoor_temp, compressor_hz, ts }
pass-through, all fields
✓ Stored and shared with the owner and their chosen service partner
↓ Incoming event
{
"event": "checkout_completed",
"user_id": "u_8812",
"plan": "pro",
"amount": 19,
"currency": "EUR",
"ts": "2026-10-31T10:02:41Z"
}
"event": "checkout_completed",
"user_id": "u_8812",
"plan": "pro",
"amount": 19,
"currency": "EUR",
"ts": "2026-10-31T10:02:41Z"
}
◇ Schema detected
event
String
LowCard
user_id
String
LowCard
plan
String
LowCard
amount
Float32
Gorilla
currency
String
LowCard
ts
DateTime64
DoubleDelta
→ Forwarded
HTTPS
events.oldvendor.com
{ event, user_id, plan, amount }
pinned to v1, unchanged
HTTPS
ingest.newvendor.eu
{ event, user_id, plan, amount, currency, ts }
backfilled, then live
90 days replayed
WebSocket
revenue dashboard
{ plan, amount, currency }
mapped, 3 fields
✓ Live to 3 destinations, 90 days replayed to ingest.newvendor.eu
Any protocol in. Any protocol out.
Many-to-one ingestion. One-to-many forwarding. Conduit translates between protocols so your services don't have to.
Sources
HTTPREST APIs · Webhooks
MQTTIoT devices · Sensors
WSReal-time streams
conduit
Schema · Store · Route
Destinations
HTTPWebhooks · APIs
MQTTBrokers · Devices
WSDashboards · UIs
MQTT sensor → HTTP webhook. WebSocket stream → MQTT broker.
One unified endpoint. Zero protocol translation code.
One unified endpoint. Zero protocol translation code.
Built for agents, not just dashboards
Connect any MCP-compatible agent. It can create streams, query data, and manage pipelines. No dashboard needed.
# AI agent connected via MCP
▸ conduit_list_events(stream: "sensors", limit: 1000)
↳ 1,000 events · 18.4 MB raw → 1.1 MB stored (94% compressed)
DoubleDelta on timestamps · Gorilla on floats · LowCardinality on strings
▸ conduit_add_forward(stream: "sensors", type: "http", url: "https://analytics.acme.io/ingest")
↳ Destination added · backfill available for 1,000 historical events
▸ conduit_stream_stats(stream: "sensors")
↳ p50: 3ms · p99: 21ms · 12,847 events/day · 30d retention
🤖 I see live sensor data flowing in. I'll pipe it to our datawarehouse and add hot storage.
▸ conduit_add_forward(stream: "sensors", type: "http", url: "https://dwh.acme.io/ingest")
↳ Destination added · forwarding to datawarehouse
▸ conduit_add_forward(stream: "sensors", type: "mqtt", broker: "mqtt://redis.acme.io", topic: "hot/sensors")
↳ Destination added · forwarding to hot storage · 3 destinations active
▸ conduit_backfill(stream: "sensors", destination: "dwh.acme.io", range: "7d")
↳ Backfilling 89,929 events from last 7 days · ETA 12s
Your schema evolves. So does Conduit.
Not rigid pipelines. Adaptive streams. Ingestion and forwarding schemas are decoupled by design.
↓ Ingestion
Store everything
New fields appear? Columns added automatically. Types change? Overflow to JSON, promote when stable. No migrations, no downtime.
✓ Auto-detect fields on first event
✓ Add columns without downtime
✓ Type-safe overflow for mismatches
✓ Auto-promote after threshold
■ Storage
Persist and replay
Every event is stored in a columnar engine built for time-series at scale. Query, backfill, or replay. Your data is always there.
✓ Columnar storage with smart compression
✓ Backfill to new destinations
✓ Time-range queries via API
✓ Configurable retention per plan
→ Forwarding
Send what they need
Each destination controls its own schema. Pass raw events through, pin to a schema version, or map fields per destination.
✓ Pass-through: forward as-is
✓ Pinned: lock to a schema version
✓ Mapped: custom field transforms
✓ Transform payloads with JavaScript before forwarding
✓ Never break a downstream consumer
"We've spent decades building data systems that optimize for predictability. But the consumers are changing. Agents handle ambiguity, models interpret structure. The infrastructure should reflect that."
Free during beta
Free while we build
Conduit is in beta. Sign up and use it: 100K events/month, 5 streams, 100 MB storage, all features included. No credit card.
Start for free →Hosted in Denmark
Storage and AI inference run on our own hardware. Trust center
~70K events/s
Batched ingest on a single node, 3 ms p50 per request. Buffered writes.
Any protocol
HTTP, WebSocket, MQTT/S. Kafka & gRPC coming soon.
AI-native MCP server
Let any MCP-compatible agent manage pipelines and query data directly.