Estuary

New Connector: Kafka Materialization

In the spirit of our commitment to integrate with the Kafka ecosystem, we've released our new Kafka Materialization connector, which allows you to push data into any Kafka broker.

Share this update

New Connector: Kafka Materialization

We’re thrilled to announce the launch of the Kafka Materialization Connector for Estuary Flow! This new feature empowers users to seamlessly materialize their data into Kafka topics, offering unparalleled flexibility and efficiency for real-time data workflows.

Key Features

Message Encoding Options

  • JSON Encoding: Simplify integration by materializing messages in JSON format, a widely adopted standard for data exchange.
  • Avro Encoding: Unlock schema validation and compact message size when paired with a Kafka schema registry.

At-Least-Once Delivery

  • The connector is built with an at-least-once non-transactional mode of operation, ensuring reliable data delivery.
  • Exactly-once soon 👀, reach out if you'd want it today!

Optimized Field Selection

  • By default, all top-level fields are recommended for materialization, enabling users to capture their complete data structure effortlessly.
  • Advanced users can customize materializations by de-selecting unnecessary top-level fields or including specific nested fields.

Streamlined Workflow

Using the Kafka Materialization Connector is straightforward:

  1. Select Kafka as the materialization destination.
  2. Configure your Kafka topic details and choose your desired encoding (JSON or Avro).
  3. Customize your field selection or go with the default to materialize the entire document.

This intuitive setup ensures users can quickly and confidently materialize data to Kafka topics without unnecessary complexity.

Why It Matters

This connector underscores our commitment to making real-time data integration simple, flexible, and powerful. Whether you're building event-driven architectures, integrating with downstream systems, or enabling analytics pipelines, the Kafka Materialization Connector delivers the tools to do so effectively.

Support

If you have any questions or feedback, don’t hesitate to reach out to our team or explore our support resources. You can send us an email here or you can join our Community Slack channel.

What’s Next

We’re continuously evolving Estuary Flow to meet your needs. While this release prioritizes at-least-once delivery, we’re open to revisiting exactly-once semantics in the future. If this is a feature you’d like to see, let us know!

Experience the new Kafka Materialization Connector today and take your real-time data workflows to the next level.

Share this update

Table of Contents

Build a Pipeline

Start streaming your data for free

Build a Pipeline
Streaming Pipelines.
Simple to Deploy.
Simply Priced.
$0.50/GB of data moved + $.14/connector/hour;
50% less than competing ETL/ELT solutions;
<100ms latency on streaming sinks/sources.