Releasesby GlyphCarry-over offsets for stopped statements in CMF 2.5.0
New statements can start processing from the Kafka offsets reached by a stopped statement by setting the sql.tables.initial-offset-from configuration property.
Also shipped Nov 1, 2026Confluent in November 2026 →
Kubernetes connector reaches end of life - 02-Nov-202
Snyk announced end-of-life support for the Kubernetes connector (kubernetes-scanner) for Insights, with data ingestion stopping on November 2, 2026.
Atlas Agent Engine in public preview
Atlas Agent Engine is now available in public preview. It provides a secure way to run AI agents at scale.
Apache Iceberg™ tables: Read and write across Snowflake accounts with Snowflake Horizon Catalog, now without managing secrets (General availability)
With this release, you can read and write Apache Iceberg™ tables managed by another Snowflake account without creating, storing, or rotating secrets. This capability is generally available through catalog integrations for Snowflake Horizon Catalog. The accounts access the same table data without copying it.
Qwen Code Release v0.26.5
Qwen Code v0.26.5 adds bounded SQL history queries for H2 and MySQL, enables Generated UI by default, and introduces Web Shell keyboard shortcuts and background agent tracking.
Qwen Code Desktop v0.26.5
Qwen Code Desktop v0.26.5 introduces bounded SQL history queries, enables Generated UI by default, and shows running background agent counts in the status bar.
More from Confluent CloudEvery Confluent Cloud release →
Apache Flink 2.3 support for SQL statements in CMF 2.5.0
Compute pools in Confluent Manager for Apache Flink 2.5.0 can run statements on Flink 2.3 in addition to Flink 1.19. Flink 2.3 is required for process table functions, batch statements, model inference, and topic-subject associations.
Shared SQL compilers and compile workers in CMF 2.5.0
CMF compiles SQL statements for the Flink version of their compute pool using compilers running in extra containers within the CMF pod. Statements for environments with artifacts compile on dedicated compile worker pods.
Process table functions in CMF 2.5.0
Users can register user-defined process table functions that accept a table input and return a table. These functions can be called from statements running on Flink 2.3 compute pools.
Batch statements support in CMF 2.5.0
Statements can run as Flink batch jobs that process bounded input, write results, and finish. The runtime mode is reported in the statement status traits.
SQL views support in CMF 2.5.0
Users can create views in the environment catalog using CREATE VIEW and read from them directly inside SQL statements.
Model inference for OpenAI in CMF 2.5.0
Models for the OpenAI provider can be registered with CREATE MODEL and invoked with ML_PREDICT from statements on Flink 2.3 compute pools once endpoints are allowed by an administrator.
AI_FORECAST and AI_DETECT_ANOMALIES functions (preview)
New AI functions enable real-time time-series forecasting via AI_FORECAST and anomaly detection via AI_DETECT_ANOMALIES using pretrained foundation models deployed in your Kubernetes cluster.
Topic-subject associations for Schema Registry in CMF 2.5.0
Kafka databases can discover Schema Registry schemas for tables through topic-subject associations, allowing tables to use schemas with subject names that differ from topic names.