Home

An advanced stream processing engine that understands streaming SQL queries to capture, analyze, and process streaming data, and allows us to integrate and act on event streams in real-time. WSO2 Streaming Integrator allows you to connect any data source to any destination with its 60+ prebuilt, production-grade connectors. It comes with a web-based IDE for designing, developing, testing, and deploying stream processing applications with a graphical drag-and-drop experience or by writing streaming SQL queries.

Quick Start Guide

Let's get started with WSO2 Streaming Integrator by running a simple integration use case in your local environment.

What can WSO2 Streaming Integrator do?

Streaming ETL with CDC

Treats data sources as streams, supports Debezium-based CDC, offers a wizard-based ETL designer, error handling, integrations with multiple systems, and provides hierarchical monitoring dashboards.

Loading and Writing Data

Enable loading, processing, and writing data in multiple formats to databases, files, and cloud storages for further processing in complex enterprise scenarios.

Stream Processing

Offers built-in connectors for various event sources and sinks, ensures at-least-once delivery with exactly-once processing, and supports transforming, enriching, cleansing, aggregating, and correlating event streams for insights.

Visual Tooling

Provides capabilities to design, develop, test, and deploy streaming integration flows with a drag-and-drop flow designer, event and feed simulation, and configurable connectors for integrating various event sources and sinks.

Monitoring

Offers monitoring metrics for CDC, file, and database interactions. Provide real-time insights into performance, usage, and errors, along with built-in chart visualizations.

Handling Errors

Enable handling of errors that may occur when processing streaming data in a graceful manner.