Flink Table API for Java generally available
The Java Table API is GA with plugin 2.3-3 on Flink 2.3.0, adding global API keys, OAuth 2.0 with identity pools, and statement lifecycle management. The Python Table API remains in Open Preview.
Also shipped Jul 16, 2026Confluent in July 2026 →
DCM Projects: New capabilities (Preview)
DCM Projects now supports the following capabilities in preview: For more information, see Supported object types in DCM Projects and Deploy and manage DCM Projects .
VOLATILE scalar UDFs are supported with dynamic table incremental refresh (General availability)
VOLATILE scalar user-defined functions (UDFs) are now supported with dynamic table incremental refresh in INCREMENTAL, AUTO, and ADAPTIVE refresh modes. This applies to scalar UDFs written in Python, Java, Scala, JavaScript, and SQL. For incremental refresh, VOLATILE UDFs are supported only in the SELECT clause.
Scala and Java UDFs in Unity Catalog are now generally available
Register Scala and Java user-defined functions (UDFs) in Unity Catalog and reuse them across notebooks, jobs, and SQL warehouses with Unity Catalog governance. Reuse existing JVM logic and get better performance than Python UDFs on all compute, including serverless. See Scala and Java user-defined functions (UDFs) in Unity Catalog .
MLflow trace storage in Unity Catalog is now generally available
MLflow trace storage in Unity Catalog tables is now generally available. Databricks recommends storing traces in Unity Catalog for new and production workloads: storage is unlimited, traces are stored in OpenTelemetry (OTel) format, access is governed through Unity Catalog schema and table permissions, and you can query traces with SQL, Genie, AI/BI...
Agentic code converter is in Beta
The agentic code converter is in Beta . Use it to convert legacy SQL dialects, such as T-SQL, Snowflake, Redshift, Oracle, BigQuery, and Teradata, to ANSI SQL in migration projects in your workspace.
Google Gemini 3 Pro is retired
Google Gemini 3 Pro is retired. Gemini 3.1 Pro is the recommended replacement. See Deprecated and retired models for migration guidance.
More from Confluent CloudEvery Confluent Cloud release →
Flink snapshot queries generally available
Snapshot queries are GA on AWS, Azure, and Google Cloud. Run bounded, batch-mode Flink SQL queries that snapshot streaming data, compute a result, and exit.
Confluent Cloud for Apache Flink adds four Azure and Google Cloud regions
New regions: Azure italynorth, mexicocentral, southafricanorth, and Google Cloud europe-southwest1 (Madrid), all with public and private networking.
Oracle XStream CDC Source supports downstream capture topologies
The XStream capture process can run on a separate downstream Oracle database, with downstream capture and cascading downstream capture topologies, in real-time and archived-log modes.
Flink REST APIs support auto pool mapping for OAuth identity pools
The Flink sqlv1 Statement and Materialized Table REST APIs make the Confluent-Identity-Pool-Id header optional, automatically mapping the OAuth token to matching identity pools.
Confluent Gateway 1.3.0 adds centralized governance enforcement (Early Access)
Gateway validates messages and enforces data governance with Schema Registry, with four policy types (schema ID, deep validation, field-level and full-payload encryption) and per-topic overrides. Docker only during EA.
Confluent Gateway supports OAuth-to-OAuth authentication swapping
Gateway supports SASL/OAUTHBEARER as a client authentication mechanism for authentication swapping between two different identity providers.
Confluent Gateway supports CyberArk Conjur secret store
Confluent Cloud Gateway 1.3.0 supports CyberArk Conjur as a secret store provider.
Confluent Gateway processes fencing filter before auth swap
Gateway now processes fencing filter requests before the authentication swap filter, so fenced clients receive BROKER_NOT_AVAILABLE immediately.