Metrics API export adds group_protocol label for consumer lag
The group_protocol label is now on the /export endpoint for consumer lag and rebalance time metrics, so you can split them by classic or consumer rebalance protocol in scrape-based tools.
Also shipped Aug 12, 2026Confluent in August 2026 →
Define business concepts with Pages (Beta)
You can now use Pages to give business terms, acronyms, and KPIs a single governed definition. Part of Unity Catalog semantics , Pages form the human-modeled layer of the Genie Ontology that Genie One draws on to ground its answers. See Pages .
Custom trace views in the MLflow trace explorer are in Beta
You can now build custom trace views in the Databricks MLflow trace explorer. Describe the layout you want in plain language, and Genie generates a reusable view that surfaces the trace fields, metrics, and feedback controls most relevant to your review workflow. See Build a custom trace view .
Google Search Console connector is available in Beta
The managed Google Search Console connector is now available in Beta in Databricks Lakeflow Connect. Use it to ingest search performance data, site metadata, and sitemap information from Google Search Console into Databricks.
Glean connector in Lakeflow Connect (Beta)
You can now ingest data from Glean into Databricks using the managed Glean connector in Lakeflow Connect. The connector ingests company-wide usage insights for search, Assistant, and agents, along with the shortcuts (go links) defined in your Glean deployment, using a Glean Client API token. This feature is in Beta . See Glean connector .
Amplitude connector (Beta)
The Amplitude connector in Lakeflow Connect is now in Beta. Ingest product analytics event data along with event, cohort, and annotation metadata from Amplitude. See Amplitude connector .
Gemini Enterprise: GitHub connector with data federation
The GitHub connector with data federation is generally available (GA) in Gemini Enterprise. The connector lets you search and act on GitHub repositories, issues, and pull requests directly from the Gemini Enterprise agent, with tool actions such as creating branches, adding issue comments, merging pull requests, and pushing files.
More from Confluent CloudEvery Confluent Cloud release →
Advanced Message Search in Open Preview
Build filters in the message browser to refine results by fields such as a customer ID anywhere in a topic's retained history, without writing a consumer or stream-processing job.
Secret manager integration adds DynamoDB, Lambda, Azure Blob, BigQuery, Redis connectors
Secret manager integration now extends to Amazon DynamoDB CDC Source and Sink, AWS Lambda Sink, Azure Blob Storage Sink, Google BigQuery Sink V2, and Redis Kafka Sink and Source.
Connector secret managers support VPC and VNet Peering
AWS Secrets Manager and Azure Key Vault integration for fully managed connectors now support VPC Peering and VNet Peering respectively, in addition to PrivateLink.
Flink FROM_CHANGELOG and TO_CHANGELOG functions generally available
Built-in changelog conversion functions read custom-format change data into queryable tables and turn updating tables back into append-only streams, with user-mapped operation codes and no UDFs required.
New in Confluent Cloud and WarpStream: Evolving the Data Streaming Platform for AI, Scale, and Control
Accelerate enterprise streaming and AI workloads with new product updates across Kora, connectors, Flink, Tableflow, AI anomaly detection and forecasting, security enhancements, and Warpstream.
New in Confluent Intelligence and AI Tools: Making Agents Native to the Stream, Expanded Model Support, New Agent Skills, and Confluent Assistant
Explore new AI features and AI tools: support for IBM Granite Time Series models and TimesFM models (EA), enhanced Real-Time Context Engine experience, new Agent Skills, Confluent Assistant
Confluent Cloud for Apache Flink: Engine for Mission-Critical, Real-Time Operational Systems and dbt/SQL-Native Home for Data Science and AI
Flink now acts as a robust engine for developers through Table API, UDFs, and PTFs while offering a SQL-native, dbt-integrated platform for data science and AI teams.
Baseline CFU for Flink statements (Limited Availability)
Set a best-effort minimum scaling target for an individual Flink statement; Autopilot keeps the statement at or above it. Configurable in Console or the Flink SQL REST API.