📄️ Filter and Route
Filter records from a stream and route results to an output topic.
📄️ Geo-Enrich Events
Add geographic information to events using IP address lookup.
📄️ Set Up Postgres CDC
Set up Change Data Capture from PostgreSQL using Debezium.
📄️ Join Two Topics
Join records from two Kafka topics by key.
📄️ Real-Time Aggregations
Count, group, and aggregate streaming data in real time.
📄️ Pipeline-as-Code
Define, validate, and manage pipelines as versioned JSON files.
📄️ Enrich with AI
Transform streaming data using OpenAI language models.
📄️ Add Semantic Search
Generate vector embeddings and sink them to Weaviate for semantic search.
📄️ Sink to Elasticsearch
Write pipeline output to an Elasticsearch index.
📄️ Enriching streams
Learn how to filter streams using the enrich operator.
📄️ Export data
Lear how to export data with the official CLI
📄️ Run data pipelines
Learn how to run data pipelines in production