Tableflow

Confluent Tableflow is a managed service that materializes Kafka topics into Apache Iceberg or Delta Lake tables, eliminating the need for custom ETL pipelines to move streaming data into analytical stores.

Reviewed by 7wData

On this page

Publisher review

Confluent Tableflow is a managed service that materializes Kafka topics into Apache Iceberg or Delta Lake tables, eliminating the need for custom ETL pipelines to move streaming data into analytical stores. It is designed for organizations already running Confluent Cloud who want to serve operational data to downstream analytics, AI, and BI tools without building and maintaining bespoke data pipelines. Tableflow automates schematization, type conversions, schema evolution, change-data-capture (CDC) stream materialization, and catalog publishing, so that data engineers can expose Kafka topics as queryable tables with minimal manual intervention. The service targets teams that have Kafka expertise and are comfortable with Confluent’s ecosystem, but it is not a general-purpose streaming platform for users who need native CDC or complex in-flight transformations.

Tableflow works by connecting to existing Kafka topics in Confluent Cloud and continuously writing the topic data into Iceberg or Delta Lake table formats. It handles schema inference and evolution automatically, so as the Kafka topic schema changes, the table schema updates without breaking downstream queries. The materialized tables are exposed as read-only through a catalog (e.g., AWS Glue, Unity Catalog, or Hive Metastore), enabling immediate querying by engines like Starburst, Trino, Snowflake, or Spark. According to Confluent’s documentation, Tableflow supports both Iceberg and Delta Lake, and it integrates with catalogs and compute engines to provide instant access for analytics and AI workloads. The service is fully managed within Confluent Cloud, meaning users do not need to deploy or operate any additional infrastructure for the materialization process.

In the market, Tableflow competes with Striim, Apache Pulsar, and Zero ETL approaches. Striim offers an all-in-one platform with native CDC and advanced in-flight transformations, which Tableflow lacks. Apache Pulsar provides a unified messaging and storage system with built-in tiered storage, but requires more operational effort. Zero ETL solutions (e.g., from Snowflake or Databricks) aim to eliminate pipelines entirely by directly connecting sources to targets, but they often have limited support for Kafka or open table formats. Tableflow’s advantage is its tight integration with Confluent Cloud and its support for both Iceberg and Delta Lake, making it a natural choice for existing Confluent customers who want a simple path from Kafka to analytics. However, it does not replace the need for a full streaming platform when complex transformations or real-time processing are required.

The honest trade-offs are significant. Tableflow requires deep Kafka expertise and a working Confluent Cloud deployment, so it is not suitable for teams new to Kafka. It lacks native CDC capabilities and advanced transformation logic, meaning users must still integrate separate tools like Debezium or Flink for those needs. Pricing is opaque and usage-based, which can drive up costs unpredictably for high-throughput or long-retention workloads. Out-of-the-box observability is minimal, so teams may need to invest in third-party monitoring to track pipeline health. Additionally, access to premium connectors may be restricted or carry extra costs, limiting the breadth of integrations without additional spend. These constraints make Tableflow a focused tool for a specific use case—materializing Kafka topics into open table formats—rather than a comprehensive data streaming solution.

Get the AI & data signal, daily.

335k+ subscribers read this every morning. One email, both newsletters. Unsubscribe anytime.

How it works

  1. Kafka-to-Iceberg materialization

    Continuously writes Kafka topic data into Apache Iceberg tables, automating schema inference and evolution without custom code.

  2. Kafka-to-Delta Lake materialization

    Supports Delta Lake as a target format, enabling direct querying by Databricks and other Delta-compatible engines.

  3. Automatic schema evolution

    Detects schema changes in Kafka topics and updates the target table schema automatically, preventing pipeline breaks.

  4. CDC stream materialization

    Materializes change-data-capture streams from Kafka into table formats, preserving insert, update, and delete operations.

  5. Catalog publishing

    Publishes materialized tables to catalogs like AWS Glue, Unity Catalog, or Hive Metastore for discovery by query engines.

  6. Read-only table exposure

    Exposes tables as read-only, allowing immediate querying by Starburst, Trino, Snowflake, or Spark without write conflicts.

  7. Fully managed within Confluent Cloud

    Operates as a managed service inside Confluent Cloud, eliminating the need for users to deploy or maintain materialization infrastructure.

Strengths and trade-offs

Strengths

  • Eliminates the need for custom ETL pipelines by automatically materializing Kafka topics into Iceberg or Delta Lake tables.
  • Supports both Apache Iceberg and Delta Lake, giving users flexibility to choose their open table format.
  • Integrates with major catalogs and compute engines, enabling instant querying from Starburst, Trino, Snowflake, and Spark.
  • Automates schema evolution and CDC materialization, reducing manual intervention and pipeline maintenance overhead.

Trade-offs

  • Requires deep Kafka expertise and a working Confluent Cloud deployment, making it inaccessible to teams without existing Kafka infrastructure.
  • Lacks native CDC and advanced transformation capabilities, forcing users to integrate separate tools like Debezium or Flink for those tasks.
  • Opaque, usage-based pricing can drive up costs unpredictably, especially for high-throughput or long-retention workloads.
  • Limited out-of-the-box observability, requiring third-party monitoring tools to achieve end-to-end pipeline visibility.

Pricing context

Not publicly disclosed; usage-based pricing within Confluent Cloud, with costs dependent on throughput, retention, and connector access tiers.

Getting started with Tableflow

  1. Sign up for Confluent Cloud

    Create a Confluent Cloud account if you don't have one. Navigate to the Confluent Cloud console and sign up with your email or a supported identity provider. Complete the onboarding steps to set up your organization and billing.

  2. Connect your Kafka topics

    In the Confluent Cloud console, select the environment and cluster where your Kafka topics reside. Ensure the topics you want to materialize are active and have a defined schema. Tableflow will read from these topics to create tables.

  3. Configure Tableflow materialization

    From the Confluent Cloud interface, enable Tableflow for your cluster. Choose the target table format (Apache Iceberg or Delta Lake) and specify the catalog (e.g., AWS Glue, Unity Catalog). Set the topic-to-table mapping and define any schema evolution rules.

  4. Run the materialization pipeline

    Start the Tableflow service to begin continuously writing Kafka topic data into the chosen table format. Monitor the initial sync in the Confluent Cloud dashboard to verify that data flows correctly and schema updates are applied automatically.

  5. Query the materialized tables

    Connect your preferred query engine (e.g., Trino, Snowflake, Spark) to the catalog where Tableflow published the tables. Run a SELECT statement to confirm the data is accessible. Schedule regular queries or integrate with BI tools for ongoing analytics.

Frequently Asked Questions

What is Confluent Tableflow?

Confluent Tableflow is a managed service that materializes Kafka topics into Apache Iceberg or Delta Lake tables. It eliminates custom ETL pipelines by automating schema inference, evolution, and catalog publishing, making streaming data queryable by analytics and AI tools.

How does Tableflow work with Kafka topics?

Tableflow connects to existing Kafka topics in Confluent Cloud and continuously writes topic data into Iceberg or Delta Lake tables. It handles schema inference and evolution automatically, so table schemas update as Kafka schemas change, without breaking downstream queries.

Does Tableflow support both Iceberg and Delta Lake?

Yes, Tableflow supports both Apache Iceberg and Delta Lake as target table formats. This gives users flexibility to choose their preferred open table format for querying by engines like Starburst, Trino, Snowflake, or Spark.

What are the main weaknesses of Tableflow?

Tableflow requires deep Kafka expertise and a Confluent Cloud deployment, lacks native CDC and advanced transformations, has opaque usage-based pricing that can spike, and offers minimal out-of-the-box observability, often needing third-party monitoring tools.

How does Tableflow pricing work?

Tableflow pricing is not publicly disclosed. It is usage-based within Confluent Cloud, with costs depending on throughput, retention, and connector access tiers. This can lead to unpredictable expenses for high-throughput or long-retention workloads.

Can Tableflow replace a full streaming platform?

No, Tableflow is not a full streaming platform. It focuses on materializing Kafka topics into open table formats. It lacks native CDC and complex in-flight transformations, so users still need tools like Debezium or Flink for those tasks.

Alternatives

How Tableflow compares

Direct head-to-head against 3 competitors. Picked by 7wData.

This tool

Tableflow

Pricing
Not publicly disclosed; usage-based pricing within Confluent Cloud, with costs dependent on throughput, retention, and connector access tiers.
Target
Confluent Tableflow is a managed service that materializes Kafka topics into Apache Iceberg or Delta Lake tables, eliminating the need for custom ETL pipelines to
Strength
Eliminates the need for custom ETL pipelines by automatically materializing Kafka topics into Iceberg or Delta Lake tables.
Watch for
Requires deep Kafka expertise and a working Confluent Cloud deployment, making it inaccessible to teams without existing Kafka infrastructure.

Streamkap

Pricing
Free trial; paid plans start at $0.50/GB processed
Target
Teams needing zero-ops CDC pipelines to warehouses and lakehouses
Deployment
SaaS, cloud
Strength
Sub-250ms latency with automatic schema evolution
Watch for
Less control over underlying infrastructure; best for CDC, not general messaging

Amazon MSK

Pricing
Pay per broker-hour; starting ~$0.21/hr per broker
Target
AWS-native teams wanting managed Kafka with full API compatibility
Deployment
AWS cloud
Strength
Native integration with IAM, VPC, CloudWatch
Watch for
Requires Kafka expertise; no built-in Iceberg/Delta conversion

Esker

Pricing
Custom enterprise pricing; typically $50k+/year
Target
Enterprise CFO offices needing full Source-to-Pay and Order-to-Cash
Deployment
SaaS, cloud
Strength
Comprehensive S2P and O2C suite for large enterprises
Watch for
6-12 month implementation; complex for mid-market ops teams

User reviews

No user reviews yet. Be the first to write one.

Sources

Reporting on this tool draws on these publicly available sources.

  1. www.reddit.com
  2. www.striim.com
  3. www.starburst.io
  4. docs.confluent.io
  5. www.confluent.io
  6. www.confluent.io
  7. medium.com