TypeStream

Getting started · Development · How to contribute · License

TypeStream connects to your Postgres or MySQL and turns every insert, update, and delete into a real-time pipeline — syncing data, enriching it with AI, and exposing it instantly.

Getting Started

Prerequisites

• Docker and Docker Compose

Start TypeStream

git clone https://github.com/typestreamio/typestream.git
cd typestream

# Copy environment template and customize
cp .env.example .env

# Start TypeStream
docker compose up -d

Open the TypeStream UI at http://localhost and start building pipelines.

Start Demo Data

To explore TypeStream with live data, add the demo overlay:

docker compose -f docker-compose.yml -f docker-compose.demo.yml up -d

This starts four data generators that produce a continuous stream of events:

Generator	What it does
Coinbase	Real-time BTC-USD and ETH-USD crypto prices via the Coinbase WebSocket API
Wikipedia	Live edit events from the English Wikipedia recent changes stream
Web Visits	Synthetic page-view events with IP addresses, user agents, and paths
File Uploads	Inserts sample documents into Postgres (captured via Debezium CDC)

Configuration

Edit .env to customize your deployment:

# Image version (defaults to latest)
TYPESTREAM_VERSION=latest

# External ports
UI_PORT=5173
KAFKA_EXTERNAL_PORT=19092
SCHEMA_REGISTRY_PORT=18081
ENVOY_PORT=8080
KAFBAT_PORT=8088

# Optional: enable AI features
OPENAI_API_KEY=your-key-here

Access Points

Service	URL
TypeStream UI	http://localhost
Kafbat (Kafka UI)	http://localhost:8088
Kafka Bootstrap	localhost:19092
Schema Registry	http://localhost:18081
gRPC-Web (Envoy)	http://localhost:8080

Stop Services

# If running with demo data
docker compose -f docker-compose.yml -f docker-compose.demo.yml down

# If running base only
docker compose down

# Remove volumes for a fresh start
docker compose down -v

Development

For contributing to TypeStream, the dev overlay swaps the UI for a hot-reload version and builds services from source.

Prerequisites

• Docker and Docker Compose
• Nix (for building the server)

Setup

# Enter the Nix dev shell
nix develop

# Start infrastructure services (Redpanda, Envoy, UI, Kafka Connect, etc.)
docker compose -f docker-compose.yml -f docker-compose.dev.yml up -d

# Run the server on your host with hot reload
./scripts/dev/server.sh

Edit Kotlin files and watch them auto-reload in ~5 seconds.

The UI is available at http://localhost:5173 with hot reload. Demo data generators (Coinbase, Wikipedia, web visits, file uploads) are included in the dev overlay and start automatically.

Stop Services

docker compose -f docker-compose.yml -f docker-compose.dev.yml down

Releasing

To create a new release:

1. Push a version tag (e.g., v1.0.0):

   git tag v1.0.0
   git push origin v1.0.0

2. The CI workflow will automatically:

   • Build and smoke test all Docker images (server, demo-data, kafka-connect)
   • Publish the images to GitHub Container Registry (ghcr.io)
   • Create a GitHub Release with placeholder notes

3. After the release is created, edit the release notes in the GitHub UI to add details about the changes.

How to Contribute

We love every form of contribution! Good entry points to the project are:

• Our contributing guidelines document.
• Issues with the tag gardening.
• Issues with the tag good first patch.

If you're not sure where to start, open a new issue or hop on to our discord server and we'll gladly help you get started.

Code of Conduct

You are expected to follow our code of conduct when interacting with the project via issues, pull requests, or in any other form. Many thanks to the awesome contributor covenant initiative!

License

TypeStream is licensed under the Business Source License 1.1.

You can use, modify, and redistribute TypeStream freely for non-production and internal purposes. Production use is permitted as long as you are not offering a competing streaming data pipeline service. Each version converts to Apache 2.0 after four years.

See LICENSE.md for the full terms.