Native Apache Kafka Service Is Coming Soon to StreamNative Cloud. Join the waitlist and get $1,000 in credits.

Join Waitlist >
StreamNative Logo

Universal Connect for Kafka & Pulsar

Unify Kafka Connect and Pulsar IO — connect, process, and monitor 200+ production-ready connectors.

Universal Connect visual

200+ production-ready connectors

Snowflake, BigQuery, MongoDB, Elastic, and more.

Kafka Connect + Pulsar IO, one framework

One runtime for connectors across both ecosystems.

Built on Ursa & One StreamNative Platform

Built into the lakehouse-native streaming platform.

CAPABILITIES

What you can do with Universal Connect

Integrate systems without building plumbing

A consistent, declarative experience for pipelines powered by Kafka Connect or Pulsar IO. Choose a connector, fill in a config, and deploy—UniConn handles the runtime, scaling, and lifecycle.

Pre-built, managed, and custom connectors

Fully managed connectors from StreamNative, partner connectors, and bring-your-own connectors all run in UniConn's unified runtime. A clear shared responsibility model tells you exactly who owns what.

Modernize your tech stack by bridging legacy & cloud

Connectors cover databases (CDC & bulk), data warehouses & lakes, SaaS & cloud services, and messaging & streaming systems. UniConn turns your streaming platform into a hub connecting legacy and modern systems.

Simplify Day-2 operations: monitor, debug, and scale

Rich logs with filters, metrics via built-in dashboards and native Datadog integration, a unified actions menu for both frameworks, and scaling without surprise costs.

Built into the lakehouse-native streaming platform

Connectors plug directly into Pulsar Service and Kafka Service. Streams can be written into Iceberg/Delta via Ursa. The same pipelines that serve applications can fuel BI, ML, and agentic AI.

USE CASES

What you can build with Universal Connect

01

Real-time CDC into streams and lakes

Stream changes from relational or NoSQL databases into Pulsar/Kafka topics and your lakehouse. Replace nightly dumps and batch ETL with continuous CDC pipelines.

02

Event-driven microservices & SaaS integration

Wire services and SaaS apps together through the streaming backbone. UniConn becomes your integration bus with fully observable, replayable streams instead of opaque point-to-point links.

03

Mainframe & legacy system offload

Bridge mainframe and legacy systems to modern analytics and apps. Stream data into Kafka/Pulsar, then into the lakehouse—modernize incrementally instead of betting on a multi-year migration.

04

Feeding AI and agents with live data

Pipe relevant tables, logs, and events into the streaming backbone. Agents via Orca can tap those connectors as tools—pulling live change events or recent batches on demand.

CONNECTORS CATALOG

Explore the Universal Connect Catalog

UniConn surfaces a growing catalog of 50+ production-ready connectors in StreamNative Cloud, plus access to 200+ Kafka Connect & Pulsar IO connectors via StreamNative Hub. Browse by framework (Kafka Connect vs Pulsar IO), category, or system.

Databases & CDC

MySQL, Postgres, Yugabyte, MongoDB, and more for change streams and bulk loads.

Data warehouses & lakes

Snowflake (including Snowpipe Streaming), BigQuery, and Iceberg/Delta connectors to keep analytics fresh.

Message & event systems

Kafka, Pulsar, MQTT and others for bridging existing messaging estates.

SaaS & cloud services

Connectors for SaaS, logs, search, and observability—so product and ops teams see live data everywhere.

Part of Our Trusted Connectors

FAQs

Universal Connect (UniConn) runs both frameworks for you. You get a single, cloud-native experience to configure, deploy, monitor, and scale connectors — across Kafka Connect and Pulsar IO (Pulsar's built-in connector framework) — without managing Connect worker clusters, pod lifecycles, or separate observability stacks.

UniConn supports fully managed connectors (built and supported by StreamNative), partner connectors, and user-provided connectors. A shared responsibility model clearly defines who owns what for each type—code, runtime, and support—so you can mix managed and custom connectors safely.

Yes. You can upload your own connectors (in-house, open source, or vendor-provided) and run them inside UniConn's unified runtime, right next to fully managed connectors, with the same monitoring and debugging experience.

UniConn is delivered as part of StreamNative Cloud today. Because it's integrated with StreamNative Cloud, you can use it with Serverless, Dedicated, BYOC, and Private Cloud deployments of the data streaming platform, while still using a consistent cloud-based control plane.

Universal Connect (UniConn) is the connectivity layer for StreamNative Cloud. It feeds data into and out of Pulsar and Kafka clusters, which are both powered by Ursa, the lakehouse-native storage engine. Because Ursa makes every topic a lakehouse table via stream-table duality, data arriving through your connectors is automatically available as Iceberg or Delta Lake tables — without additional integration work.

It's easy to get connected with UniConn

  • Sign in to StreamNative Cloud.
  • Open Universal Connect (UniConn) and browse the connector catalog.
  • Pick a source and sink, fill in the config, and deploy.
  • Watch metrics and logs in the UniConn console—or pipe them into your existing observability stack.