Public · Mountain View, US · 77 releases · 1 this month
Also onAcquisitions·Paydays(Pay schedule)·TechConf(7 conferences)
Confluent released updates including Lightning Tables, Managed Model Inference, and multi-tenancy for CPC. The release also adds Tableflow support for Google Cloud to improve streamhouse architectures.
The Apache Software Foundation released Apache Kafka 4.4.0, which includes new features and performance improvements.
Apache Kafka 4.4.0 introduces new features and improvements across broker, controller, producer, consumer, admin client, and Kafka Streams components. This release includes updates to cluster metadata bootstrapping, share group dead-letter queues, and transactional state stores.
Confluent Cloud has secured OSPAR attestation, providing financial institutions in Singapore with verified assurance for outsourced data streaming.
The Oracle XStream CDC Source connector now captures Oracle RAW and XMLType columns. XMLType columns must be explicitly serialized to CLOB for snapshot operations.
Users can now delete consumer groups that are in an empty state directly through the Confluent Cloud Console.
Confluent Cloud audit logs now record events for SCIM provisioning operations. This includes enabling SCIM, managing tokens, and user lifecycle management.
The Advanced Security add-on is now available as a Limited Availability release. It bundles capabilities including SCIM, self-managed encryption keys, and higher limits for security-related resources.
Java plugin 2.3-6 and Python package 2.3.3 on Flink 2.3.0 add AI_SENTIMENT, AI_DETECT_PII, AI_FORECAST and AI_DETECT_ANOMALIES, FROM_CHANGELOG/TO_CHANGELOG support, and ConfluentTools.createArtifact(). Python Table API remains in Open Preview.
The connector no longer requires granting SELECT_CATALOG_ROLE to the connect user; you can instead grant SELECT on an explicit list of catalog views.
The logicalCluster OAuth extension is no longer required for clients connecting to Dedicated, Freight, and Enterprise clusters with an lkc-based bootstrap URL, on any cloud or networking type.
Custom SMTs on fully managed connectors can call endpoints outside Confluent Cloud, such as KMS, secret stores, or data enrichment APIs, as a Limited Availability feature.
IP filtering now protects public Kafka and ksqlDB access, expanding on support for resource management, schema management, and Flink.
The input key format is now configurable for IBM MQ Sink connectors on Confluent Cloud.
USM monitors conditions such as offline partitions, broker storage exhaustion, and stalled telemetry, delivering alerts to Console, email, Slack, Microsoft Teams, or a webhook.
The idle session timeout increases from 30 minutes to two hours, measured by console interaction. The eight-hour maximum session length is unchanged.
The built-in functions now support IBM Granite TTM, FlowState, and PatchTST-FM models as an Early Access Program feature, alongside Google TimesFM 2.5.
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.
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.
Autopilot keeps statements that use Java UDFs processing data while it scales them. Existing statements get the behavior after their next restart; Python UDFs are unaffected.
Single sign-on configuration now has its own page in Cloud Console, separate from Accounts & access, where group mapping configuration remains.
The fully managed Amazon S3 Sink and Snowflake Sink connectors now connect to destinations in a different region or cloud without contacting Confluent Support.
The AWS Lambda Sink connector supports STRING as an input.data.format value and a new input.key.format setting, defaulting to BYTES.
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.
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.
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.
New regions: Azure italynorth, mexicocentral, southafricanorth, and Google Cloud europe-southwest1 (Madrid), all with public and private networking.
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.
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.
Opt-in safeguard that blocks deletion of a Kafka cluster until an authorized user disables it. Available via Console, CLI, REST API, or Terraform.
The mTLS certificate revocation list size limit drops from 10 MB to 1.5 MB per CRL, and public CAs no longer support issuing client certificates.
The metric now reports lag for any group in the EMPTY state for less than one day, rolling out through late August 2026.
Dedicated clusters with Premier support or higher can enable release priority to receive updates before non-test clusters.
Custom Single Message Transformations are now available for fully managed connectors on Basic, Standard, and public Dedicated clusters in all supported regions.
Confluent Cloud can fetch connector secrets at runtime from Google Cloud Secret Manager, removing the need to persist secrets within Confluent's boundary.
Materialize topics with encrypted fields into Iceberg or Delta Lake tables, storing tagged fields as plaintext if you share the key or as ciphertext if you keep it private.
PTFs provide managed state, state TTL, event-time timers, and multi-table inputs. This release adds changelog mode via the SUPPORT_UPDATES trait.
| Release-notes page | Site | Feed |
|---|---|---|
| Confluent Cloud release notes docs.confluent.io | docs.confluent.io | None |
| Apache Kafka clients changelog (librdkafka) github.com | github.com | RSS |
| Confluent CLI release notes docs.confluent.io | docs.confluent.io | None |
| Confluent Manager for Apache Flink docs.confluent.io | docs.confluent.io | None |
| Confluent Platform release notes docs.confluent.io | docs.confluent.io | None |
| Terraform provider changelog github.com | github.com | None |
| Terraform provider releases github.com | github.com | RSS |
Releasesby Glyph