Declarative streaming library powered by Effect.js, inspired by Apache Camel and Benthos
npm install @chimpbase/connect

Chimpbase Connect moves streaming data between services with minutes of setup. Declarative pipelines, a production-grade runtime, and first-class observability let product teams run webhooks, queue bridges, and data fan-out jobs without bespoke glue code.
Built for teams that need:
- Webhook ingestion with deterministic forwarding
- Queue-to-queue synchronization across services
- Lightweight streaming jobs that can be monitored and tuned from the CLI
``bash`
npx @chimpbase/connect --helpor
npm install -g @chimpbase/connect
`yaml
input:
http:
port: 8080
path: "/webhook"
pipeline:
processors:
- metadata:
correlation_id_field: "correlationId"
output:
http:
url: "https://api.example.com/events"
method: POST
`
`bash`
npx @chimpbase/connect run my-pipeline.yaml
chimpbase-connect run my-pipeline.yaml --debug # after global install
chimpbase-connect run my-pipeline.yaml --once # process available messages and exit
Use structured logs for quick triage or forward metrics/traces to your preferred observability stack via the built-in exporters.
(soon mirrored on the public documentation site).Resources & next steps
- docs/ – Local copies of detailed guides until the public docs site launches.
- configs/ – Ready-made pipeline examples to clone or adapt.
- docs/TESTING.md` – How to validate pipelines with YAML or programmable harnesses.