2026年11月4日 リリースメモ
Confluent CLI の新しい confluent flink query コマンドは、スナップショットクエリとして限定された Flink SQL 文を実行し、完了するのを待ち、結果をプリントします。スクリプトやワンタイムクエリは、結果を得るためにステートメントハンドルを投票する必要はありません。詳細については、クエリを実行を参照してください。
Confluent CLI の新しい confluent flink query コマンドは、スナップショットクエリとして限定された Flink SQL 文を実行し、完了するのを待ち、結果をプリントします。スクリプトやワンタイムクエリは、結果を得るためにステートメントハンドルを投票する必要はありません。詳細については、クエリを実行を参照してください。
Unified Stream Manager では、Confluent Platform で実行されるカフカクラスターに加えて、Confluent Cloud でホストされているカフカクラスターに対して実行される自己管理のConnectクラスターの登録とモニタリングがサポートされています。詳細については、Confluent Cloudの自己管理コネクタを参照してください。
Unified Stream Manager は、登録された Confluent Platform クラスターの RBAC をサポートし、UsmClusterAdmin,UsmOperator,および MetricsViewer ロールはそれぞれ管理者、読み取りのみ、メトリックのみのアクセスを提供します。詳細については、Unified Stream Managerの役割ベースのアクセス制御を参照してください。
LATERAL SNAPSHOT は、Apache Flink の Confluent Cloud で、一般に利用可能になりました。LATERAL SNAPSHOT join を使って、ストリームの各行を顧客や製品データなどの参照表の現在のバージョンで豊かにします。リンクはまず参照表全体を読み込み、新しい行が到着する度にリンクします。 そのため、めったに変化しない参照表は、結果を遅らせません。それは。..
Apache Flink用のConfluent Cloudのストリーミングブートストラップは、オープンプレビュー機能として現在利用できます。ストリーミング・ブートストラップでは、連続的なクエリは、バッチモードで歴史的なデータから状態を構築し、その後ストリーミングクエリとしてライブデータを処理します。AWSでは、ストリーミング・ブートストラップは Tableflow テーブルから過去記録と Kafka の最近の記録を読み取ることができます。詳細については、Stream を参照してください。
Confluent Cloud は Apache Kafka® 4.4 から以下のクライアントと Kafka Streams 機能をサポートしています。これらの機能を使用するには、Kafka Java Client と Kafka Streams アプリケーションをバージョン 4.4 以降にアップグレードしてください。Kafka Streams ドメイン特有の言語 (DSL) オペレーターは、ヘッダー認識 KeyValue,ウィンドウ、セッション状態ストアにオプトインし、ステートストア読み込みと書き込みを通じてレコードヘッダを保存することができます。
Apache Flink用のConfluent Cloudは、AWS,Azure,Google Cloudで実行されるコンピューティングプールで管理されたAIモデルをサポートしています。Confluentはモデルを管理します モデルプロバイダーと接続せずに AIモデル推論を実行できます詳細については",管理されたAIモデルを実行する"を参照してください。
完全に管理されている HTTP Source V2 と HTTP Sink V2 コンネクタは、OpenAPI仕様ファイルなしで手動設定をサポートしています。コネクタを手動で設定するには、Open API 仕様を使用するタグをオフにして、API ベース URL とエンドポイント パスを入力します。詳細については、HTTP ソース V2 と HTTP Sink V2 を参照してください。
管理されている MCP サーバ、リアルタイムコンテキスト エンジン MCP サーバを含むものへのサインインは、 API キーではなく OAuth で Confluent Cloud アカウントでできます。MCPツールは、自分の権限で動作します。詳細については、Confluent Cloudアカウントサインイン (OAuth) を参照してください。
上昇書き込みモードを使用するときにインデックス関連処理のためのテーブルフロー請求書。詳細については、Confluent Cloud での Tableflow での請求を参照してください。
Confluent Cloud とのシークレットマネージャー統合は、Snowflake Source コンネクタまで拡張されています。詳細については、Confluent Cloudで秘密管理者統合を作成を参照してください。
クラフトのコントロールの状態を USM で監視できます登録されたConfluent Platformクラスタのブローカータブでは、現在、総コントローラ数、アクティブコントローラID,クラスタにクオラムがあるかどうか、および時間の経過とともにアクティブおよびスタンバイコントローラグラフが表示されます。KRaftのコントローラモニタリングには サポートされているコンフルーント・プラットフォームバージョンが必要です
2つのデベジウム単一のメッセージ変換 (SMT) が完全に管理されているデベジウム変更データキャプチャ (CDC) 向けに利用可能になりました。 ソースコネクタをコンフルーントクラウドで: ExtractChangedRecordState: UPDATE 操作によって変更または変更されていないフィールドをリストするメッセージヘッダを追加します。この方法により、下流消費者は、実地レベルの変化を検出し、有効負荷構造の前後を比較することなく検出できます。もっと。..
地域間およびクラウド間接続のサポートは、現在、完全管理された Google BigQuery V2 Sink と MongoDB Atlas Sink コンフルーントクラウドのコネクタに拡張されています。Confluent Cloud クラスタとは異なる地域やクラウドプロバイダの宛先に接続するには、Confluent サポートに連絡する必要はありません。
librdkafka v2.16.0 で動作する更新された Confluent Kafka クライアントは、Python クライアント、JavaScript クライアント、 .NET クライアント、Go クライアント、および C/C++ クライアントで利用できます。このリリースでは: Python Client の無料スレッドサポート IBM Z s390x プラットフォームの Python Client,JavaScript Client,および .NET Client Topic Subject Association 管理 API のサポートを提供しています。詳細については、 librdkafka と派生クライアントを参照してください。..
貨物クラスタは、キーベースのコンパクトストレージ、アイデントポテンスの生産者、トランザクション、DELETE_RECORDSとREPLICA_STATUS操作をサポートしています。詳細については、貨物クラスターの考慮を参照してください。
完全に管理されている Marketo Sink コネクタは、AWS,Azure,Google Cloud の Apache Kafka® クラスタで一般に利用できます。カフカからのレコードをAdobe Marketo Engageにストリームするように設定します。 リードをアップセル、カスタムアクティビティをログ、カスタムオブジェクトをアップセル、静的なリストメンバーシップを管理します。その機能の全範囲を調査し、開始するには、Confluent CloudのMarketo Sink Connectorを参照してください。..
完全管理された Azure Data Explorer (Kusto) Database Sink Connector for Confluent Cloud は、AWS,Azure,Google Cloud の Apache Kafka® クラスターで一般に利用可能になりました。このコネクターは、Apache Kafka®トピックからのイベントを Azure Data Explorer (Kusto) データベーステーブルにストリーミングします。詳細については、Azure Data E を参照してください。
mTLS認証は、現在 Azure Enterprise クラスターで一般的に利用できます。詳細については、相互TLS (mTLS) 認証の設定を参照してください。
Tableflow は Google Cloud で一般公開されています。Apache Kafka®トピックは、Confluent Managed Storageや Google Cloud Storageのバケットに保存されている Apache IcebergTMテーブルとして公開できます。詳細については、Google Cloud Storage で Tableflow データを格納する を参照してください。
Oracle XStream CDC ソースコネクタが完全に管理されているため、Oracle RAW と XMLType の列をキャプチャします。XMLType 列をクエリするカスタムスナップショット SELECT ステートメントとアドホックブロックスナップショットフィルターは、XMLSERIALIZE を使用してCLOBに明確にシリアル化する必要があります。詳細については、Large object (LOB) タイプとXMLTypeの処理とサポートされるデータタイプを参照してください。
Confluent Cloud Console を使って、空っぽ状態のユーザーグループを削除できます。グループが空っぽに見えて削除要求を受け入れますが、消費者はまだ消費できます。詳細については、カフカの消費者の遅延を監視するためにConfluent Cloud Consoleを使用するを参照してください。
Confluent Cloudの監査ログは、組織向けにSCIMを有効にし、SCIMトークンを管理し、SCIMクライアントを通じてユーザを作成、更新、または削除するなど、System for Cross-domain Identity Management (SCIM) のプロビジョニング操作の監査可能なイベントを記録している。詳細については、Confluent CloudにおけるSCIM監査可能なイベント方法を参照してください。
Advanced Security アドオンが Confluent Cloud で Limited Availability リリースとして提供されています。この組織レベルのアドオンには、クロスドメインアイデンティティ管理システム (SCIM),自己管理暗号鍵 (BYOK),グループマッピング、アイデンティティプール、RBACロールバインドなどの選択されたセキュリティ関連リソースの高い制限を含む高度なセキュリティ機能がパッケージ化されています。アドオン。..
Flink Table API for Confluent Cloud for Apache Flink は、Javaプラグインバージョン2.3-6とPythonパッケージバージョン2.3.3に更新され、以下のような機能が追加されています。 AI関数: AI_SENTIMENTとAI_DETECT_PIIスカラー関数とAI_FORECASTとAI_DETECT_ANOMALIES総関数はConfluentMLExpressionsを通じてサポートされています。チェンジログの機能: FROM_CHANGELOG と。..
Tableflow は、RECORDNAMEStrategy や TopicRecordNameStrategy を制限可用性機能として使用するトピックをサポートしています。複数のイベントタイプを持つトピックを 1 つのテーブルにマテリアル化できますアクセスを要求するには Confluent サポートに連絡してください詳細については、RecordNameStrategy または TopicRecordNameStrategy を使用するを参照してください。
Oracle XStream CDC Source コンネクタには、以下の更新プログラムが含まれています。オプション SELECT_CATALOG_ROLE: コンネクタは、接続ユーザーに SELECT_CATALOG_ROLE を許可する必要がなくなりました。カタログビューの明示的なリストに SELECT を許可できます詳細については、データベースユーザの設定を参照してください。アクティブ・データ・ガード 待機サポート 下流のキャプチャのキャスケード
ロジカルクラスターID OAuth拡張子、例えば、logicalCluster または extension_logicalCluster は、次のクラスタータイプに接続する Kafka クライアントでは、クラウドプロバイダーまたはネットワークタイプ:専用クラスター 貨物クラスター lkc ベースのブートストラップ URL を備えたエンタープライズクラスターについては、コンフルーント クラウド クライアントの OAuth 構成参照を参照してください。
Apache Flink® の Confluent Cloud でのユーザー定義機能 (UDF) は、現在、追加の AWS 地域と 2 つの Azure 地域で利用できます。 AWS: ap-southeast-7 (バンコク、タイ) Azure: italynorth (ミラノ、イタリア), mexicocentral (Querétaro,メキシコ) すべてのクラウドにおける地域別能力マトリックスについては、UDF 地域利用可能性を参照してください。
Confluent Cloud の完全に管理されているコネクタ上のカスタム SMT は、現在、リミテッド・アベイラビリティ機能として外部ネットワークコール (出口) を行うことができます。外部出口を有効にすると、Confluent Cloudの外部のエンドポイント、例えばキー管理サービス (KMS),秘密ストア、またはデータ強化 API に接続できます。詳細については、カスタム SMT から外部ネットワーク コールを有効にするを参照してください。