Confluent has released a dbt adapter for Confluent Cloud's Apache Flink SQL, enabling data engineers to manage streaming pipelines using familiar dbt workflows. The dbt-confluent adapter introduces new materializations for streaming (streaming_table, streaming_source, and view), backed by an open-source DB-API v2 Python driver that communicates directly with the Confluent Cloud REST API. A key feature is automatic switching to bounded/snapshot execution mode during tests, solving the historically difficult problem of deterministic testing for unbounded streaming queries. The adapter supports standard dbt commands (dbt run, dbt test, dbt docs), CI/CD integration via GitHub Actions, and unit testing with mock data. Install via pip install dbt-confluent.
